Base implementation for subscription More...
Protected Member Functions | |
abstract void | OnMessageOnProducerThread (T msg) |
Called after message has been filtered. More... | |
Properties | |
Filter< T > | FilterOnProducerThread [get, set] |
ISubscribable<T>.FilterOnProducerThread More... | |
abstract ISubscriptionRegistry | Subscriptions [get] |
Properties inherited from ExitGames.Concurrency.Channels.ISubscribable< T > | |
Filter< T > | FilterOnProducerThread [get, set] |
Filter called from producer threads. Should be thread safe as it may be called from multiple threads. More... | |
Properties inherited from ExitGames.Concurrency.Channels.IProducerThreadSubscriber< T > | |
ISubscriptionRegistry | Subscriptions [get] |
Additional Inherited Members | |
Public Member Functions inherited from ExitGames.Concurrency.Channels.IProducerThreadSubscriber< T > | |
void | ReceiveOnProducerThread (T msg) |
Method called from producer threads More... | |
Base implementation for subscription
T |
|
protectedpure virtual |
Called after message has been filtered.
msg |
Implemented in ExitGames.Concurrency.Channels.ChannelSubscription< T >, ExitGames.Concurrency.Channels.KeyedBatchSubscriber< TKey, T >, ExitGames.Concurrency.Channels.LastSubscriber< T >, and ExitGames.Concurrency.Channels.BatchSubscriber< T >.
|
getset |
|
get |