Creates a queue that will deliver a message to a single consumer. Load balancing can be achieved by creating multiple subscribers to the queue. More...
Public Member Functions | |
IDisposable | Subscribe (IExecutionContext executionContext, Action< T > onMessage) |
Subscribe to the context. More... | |
void | Publish (T message) |
Pushes a message into the queue. Message will be processed by first available consumer. More... | |
Creates a queue that will deliver a message to a single consumer. Load balancing can be achieved by creating multiple subscribers to the queue.
T |
void ExitGames.Concurrency.Channels.IQueueChannel< T >.Publish | ( | T | message | ) |
Pushes a message into the queue. Message will be processed by first available consumer.
message |
Implemented in ExitGames.Concurrency.Channels.QueueChannel< T >.
IDisposable ExitGames.Concurrency.Channels.IQueueChannel< T >.Subscribe | ( | IExecutionContext | executionContext, |
Action< T > | onMessage | ||
) |
Subscribe to the context.
executionContext | |
onMessage |
Implemented in ExitGames.Concurrency.Channels.QueueChannel< T >.