Default QueueChannel implementation. Once and only once delivery to first available consumer. More...
Public Member Functions | |
IDisposable | Subscribe (IExecutionContext executionContext, Action< T > onMessage) |
Subscribe to executor messages. More... | |
void | Publish (T message) |
Publish message onto queue. Notify consumers of message. More... | |
Default QueueChannel implementation. Once and only once delivery to first available consumer.
T |
|
inline |
Publish message onto queue. Notify consumers of message.
message |
Implements ExitGames.Concurrency.Channels.IQueueChannel< T >.
|
inline |
Subscribe to executor messages.
executionContext | |
onMessage |
Implements ExitGames.Concurrency.Channels.IQueueChannel< T >.