Namespace Orleans.Streams
Classes
AsyncObservableExtensions
ClusterClientPubSubStreamConfigurator<TDataAdapter>
ClusterClientSqsStreamConfigurator
RegexStreamNamespacePredicate
IStreamNamespacePredicate implementation allowing to filter stream namespaces by regular expression.
SiloPubSubStreamConfigurator<TDataAdapter>
SiloSqsStreamConfigurator
StreamSequenceToken
Handle representing stream sequence number/token. Consumer may subsribe to the stream while specifying the start of the subsription sequence token. That means that the stream infarstructure will deliver stream events starting from this sequence token.
StreamSequenceTokenUtilities
StreamSubscriptionHandle<T>
Handle representing this subsription. Consumer may serialize and store the handle in order to unsubsribe later, for example in another activation on this grain.
StreamSubscriptionHandleExtensions
Interfaces
IAsyncBatchObserver<T>
This interface generalizes the IAsyncObserver interface to allow production and consumption of batches of items.
Note that this interface is implemented by item consumers and invoked (used) by item producers. This means that the consumer endpoint of a stream implements this interface.
IAsyncObservable<T>
This interface generalizes the standard .NET IObserveable interface to allow asynchronous consumption of items. Asynchronous here means that the consumer can process items asynchronously and signal item completion to the producer by completing the returned Task.
Note that this interface is invoked (used) by item consumers and implemented by item producers. This means that the producer endpoint of a stream implements this interface.
IAsyncObserver<T>
This interface generalizes the standard .NET IObserver interface to allow asynchronous production of items.
Note that this interface is implemented by item consumers and invoked (used) by item producers. This means that the consumer endpoint of a stream implements this interface.
IAsyncStream<T>
This interface represents an object that serves as a distributed rendevous between producers and consumers. It is similar to a Reactive Framework
Subject
and implements
IObserver
nor IObservable
interfaces.
IStreamIdentity
IStreamNamespacePredicate
Stream namespace predicate used for filtering implicit subscriptions using ImplicitStreamSubscriptionAttribute.