Interface IStreamProvider

Namespace: Orleans.Streams
Assembly: Orleans.Core.Abstractions.dll
Syntax
public interface IStreamProvider

Properties

| Improve this Doc View Source

IsRewindable

Determines whether this is a rewindable provider - supports creating rewindable streams (streams that allow subscribing from previous point in time).

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

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

Name

Name of the stream provider.

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

Methods

| Improve this Doc View Source

GetStream<T>(Guid, String)

Declaration
IAsyncStream<T> GetStream<T>(Guid streamId, string streamNamespace)
Parameters
Type Name Description
Guid streamId
System.String streamNamespace
Returns
Type Description
IAsyncStream<T>
Type Parameters
Name Description
T

Extension Methods

Orleans.Streams.PubSub.StreamSubscriptionManagerExtensions.TryGetStreamSubscrptionManager(Orleans.Streams.IStreamProvider,Orleans.Streams.Core.IStreamSubscriptionManager@)