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.

IStreamProvider

Delegates

StreamFilterPredicate