Classes | |
class | BaseSubscription |
Base implementation for subscription More... | |
class | BatchSubscriber |
Batches actions for the consuming thread. More... | |
class | Channel |
Default Channel Implementation. Methods are thread safe. /summary> typeparam name="T"> More... | |
class | ChannelRequest |
class | ChannelSubscription |
Subscription for actions on a channel. More... | |
interface | IChannel |
A channel provides a conduit for messages. It provides methods for publishing and subscribing to messages. The class is thread safe. More... | |
interface | IProducerThreadSubscriber |
Action subscriber that receives actions on producer thread. More... | |
interface | IPublisher |
Channel publishing interface. More... | |
interface | IQueueChannel |
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... | |
interface | IReply |
Used to receive one or more replies. More... | |
interface | IReplySubscriber |
Methods for working with a replyChannel More... | |
interface | IRequest |
A request object that can be used to send 1 or many responses to the initial request. More... | |
interface | IRequestPublisher |
interface | IRequestReplyChannel |
Typed channel for request/reply More... | |
interface | ISnapshotChannel |
An ISnapshotChannel is a channel that allows for the transmission of an initial snapshot followed by incremental updates. The class is thread safe. /summary> typeparam name="T"> More... | |
interface | ISubscribable |
Callback method and parameters for a channel subscription More... | |
interface | ISubscriber |
Channel subscription methods. More... | |
class | KeyedBatchSubscriber |
Channel subscription that drops duplicates based upon a key. More... | |
class | LastSubscriber |
Subscribes to last action received on the channel. More... | |
class | QueueChannel |
Default QueueChannel implementation. Once and only once delivery to first available consumer. More... | |
class | QueueConsumer |
class | RequestReplyChannel |
Channel for synchronous and asynchronous requests. More... | |
class | SnapshotChannel |
A SnapshotChannel is a channel that allows for the transmission of an initial snapshot followed by incremental updates. The class is thread safe. /summary> typeparam name="T"> More... | |
class | Unsubscriber |
Functions | |
delegate bool | Filter< T > (T msg) |
Message filter delegate More... | |
delegate bool ExitGames.Concurrency.Channels.Filter< T > | ( | T | msg | ) |
Message filter delegate
T |
msg |