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.
Inherited Members
Namespace: Orleans.Streams
Assembly: Orleans.Core.Abstractions.dll
Syntax
public interface IAsyncStream<T> : IStreamIdentity, IEquatable<IAsyncStream<T>>, IComparable<IAsyncStream<T>>, IAsyncObservable<T>, IAsyncBatchObserver<T>, IAsyncObserver<T>
Type Parameters
Name Description
T

The type of object that flows through the stream.

Properties

| Improve this Doc View Source

IsRewindable

Determines whether this is a rewindable stream - supports subscribing from previous point in time.

Declaration
bool IsRewindable { get; }
Property Value
Type Description
System.Boolean

True if this is a rewindable stream, false otherwise.
| Improve this Doc View Source

ProviderName

Stream Provider Name.

Declaration
string ProviderName { get; }
Property Value
Type Description
System.String

Methods

| Improve this Doc View Source

GetAllSubscriptionHandles()

Retrieves a list of all active subscriptions created by the caller for this stream.

Declaration
Task<IList<StreamSubscriptionHandle<T>>> GetAllSubscriptionHandles()
Returns
Type Description
Task<IList<StreamSubscriptionHandle<T>>>

Extension Methods