public class ConsumerWorkService

Field Summary

Flags Type Name Summary
public const int MAX_THUNK_EXECUTION_BATCH_SIZE

(undocumented)

Property Summary

Flags Type Name Summary
public int ShutdownTimeout (r)

(undocumented)

Constructor Summary

Flags Name Summary
public ConsumerWorkService()

(undocumented)

public ConsumerWorkService(TaskScheduler scheduler)

(undocumented)

Method Summary

Flags Name Summary
public void AddWork(IModel model, Action fn)

(undocumented)

public void ExecuteThunk()

(undocumented)

public void RegisterKey(IModel model)

(undocumented)

public void StopWork(IModel model)

(undocumented)

public void StopWork()

(undocumented)

Field Detail

public const int MAX_THUNK_EXECUTION_BATCH_SIZE

Property Detail

public int ShutdownTimeout (r)

Constructor Detail

ConsumerWorkService

public ConsumerWorkService()

ConsumerWorkService

public ConsumerWorkService(TaskScheduler scheduler)

Parameters
Name Type
scheduler TaskScheduler

Method Detail

AddWork

public void AddWork(IModel model, Action fn)

Flags public
Return type void
Parameters
Name Type
model IModel
fn Action

ExecuteThunk

public void ExecuteThunk()

Flags public
Return type void

RegisterKey

public void RegisterKey(IModel model)

Flags public
Return type void
Parameters
Name Type
model IModel

StopWork

public void StopWork(IModel model)

Flags public
Return type void
Parameters
Name Type
model IModel

StopWork

public void StopWork()

Flags public
Return type void