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 SourceIsRewindable
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. |
ProviderName
Stream Provider Name.
Declaration
string ProviderName { get; }
Property Value
Type | Description |
---|---|
System.String |
Methods
| Improve this Doc View SourceGetAllSubscriptionHandles()
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>>> |