Default Channel Implementation. Methods are thread safe. /summary> typeparam name="T"> More...
Public Member Functions | |
IDisposable | Subscribe (IFiber fiber, Action< T > receive) |
ISubscriber<T>.Subscribe(IFiber,Action<T>) More... | |
IDisposable | SubscribeToBatch (IFiber fiber, Action< IList< T >> receive, int intervalInMs) |
ISubscriber<T>.SubscribeToBatch(IFiber,Action<IList<T>>,int) More... | |
IDisposable | SubscribeToKeyedBatch< TOutput > (IFiber fiber, Converter< T, TOutput > keyResolver, Action< IDictionary< TOutput, T >> receive, int intervalInMs) |
ISubscriber<T>.SubscribeToKeyedBatch<K>(IFiber,Converter<T,K>,Action<IDictionary<K,T>>,int) More... | |
IDisposable | SubscribeToLast (IFiber fiber, Action< T > receive, int intervalInMs) |
Subscription that delivers the latest message to the consuming thread. If a newer message arrives before the consuming thread has a chance to process the message, the pending message is replaced by the newer message. The old message is discarded. More... | |
IDisposable | SubscribeOnProducerThreads (IProducerThreadSubscriber< T > subscriber) |
Subscribes to actions on producer threads. Subscriber could be called from multiple threads. More... | |
void | ClearSubscribers () |
Remove all subscribers. More... | |
Public Member Functions inherited from ExitGames.Concurrency.Channels.IPublisher< T > | |
bool | Publish (T msg) |
Publish a message to all subscribers. Returns true if any subscribers are registered. More... | |
Properties | |
bool | HasSubscriptions [get] |
Gets a value indicating if this instance has subscriptions. More... | |
int? | NumSubscribers [get] |
Default Channel Implementation. Methods are thread safe. /summary> typeparam name="T">
|
inline |
Remove all subscribers.
Implements ExitGames.Concurrency.Channels.ISubscriber< T >.
|
inline |
ISubscriber<T>.Subscribe(IFiber,Action<T>)
fiber | |
receive |
Implements ExitGames.Concurrency.Channels.ISubscriber< T >.
|
inline |
Subscribes to actions on producer threads. Subscriber could be called from multiple threads.
subscriber |
Implements ExitGames.Concurrency.Channels.IChannel< T >.
|
inline |
ISubscriber<T>.SubscribeToBatch(IFiber,Action<IList<T>>,int)
fiber | |
receive | |
intervalInMs |
Implements ExitGames.Concurrency.Channels.ISubscriber< T >.
|
inline |
ISubscriber<T>.SubscribeToKeyedBatch<K>(IFiber,Converter<T,K>,Action<IDictionary<K,T>>,int)
TOutput |
fiber | |
keyResolver | |
receive | |
intervalInMs |
Implements ExitGames.Concurrency.Channels.ISubscriber< T >.
|
inline |
Subscription that delivers the latest message to the consuming thread. If a newer message arrives before the consuming thread has a chance to process the message, the pending message is replaced by the newer message. The old message is discarded.
fiber | |
receive | |
intervalInMs |
Implements ExitGames.Concurrency.Channels.ISubscriber< T >.
|
get |
Gets a value indicating if this instance has subscriptions.
|
get |