StreamSubscriptionManagerExtensions Methods

Extension methods for IStreamSubscriptionManager.

AddSubscription(IStreamSubscriptionManager, IGrainFactory, StreamId, string, GrainId)

staticextension

public static Task<StreamSubscription> AddSubscription<TGrainInterface>(this IStreamSubscriptionManager manager, IGrainFactory grainFactory, StreamId streamId, string streamProviderName, GrainId grainId)

Subscribes the specified grain to the specified stream.

Parameters

managerIStreamSubscriptionManager: The manager.
grainFactoryIGrainFactory: The grain factory.
streamIdStreamId: The stream identifier.
streamProviderNamestring: Name of the stream provider.
grainIdGrainId: The grain to subscribe.

Returns

The newly added subscription.

AddSubscription(IStreamSubscriptionManager, IGrainFactory, StreamId, string, Guid, string)

staticextension

View source

public static Task<StreamSubscription> AddSubscription<TGrainInterface>(this IStreamSubscriptionManager manager, IGrainFactory grainFactory, StreamId streamId, string streamProviderName, Guid primaryKey, string grainClassNamePrefix = null)

Subscribes the specified grain to the specified stream.

Parameters

managerIStreamSubscriptionManager: The manager.
grainFactoryIGrainFactory: The grain factory.
streamIdStreamId: The stream identifier.
streamProviderNamestring: Name of the stream provider.
primaryKeyGuid: The grain's primary key.
grainClassNamePrefixstring: The grain class name prefix.

Returns

The newly added subscription.

AddSubscription(IStreamSubscriptionManager, IGrainFactory, StreamId, string, Guid, string, string)

staticextension

View source

public static Task<StreamSubscription> AddSubscription<TGrainInterface>(this IStreamSubscriptionManager manager, IGrainFactory grainFactory, StreamId streamId, string streamProviderName, Guid primaryKey, string keyExtension, string grainClassNamePrefix = null)

Subscribes the specified grain to the specified stream.

Parameters

managerIStreamSubscriptionManager: The manager.
grainFactoryIGrainFactory: The grain factory.
streamIdStreamId: The stream identifier.
streamProviderNamestring: Name of the stream provider.
primaryKeyGuid: The grain's primary key.
keyExtensionstring: The grain's key extension.
grainClassNamePrefixstring: The grain class name prefix.

Returns

The newly added subscription.

AddSubscription(IStreamSubscriptionManager, IGrainFactory, StreamId, string, long, string)

staticextension

View source

public static Task<StreamSubscription> AddSubscription<TGrainInterface>(this IStreamSubscriptionManager manager, IGrainFactory grainFactory, StreamId streamId, string streamProviderName, long primaryKey, string grainClassNamePrefix = null)

Subscribes the specified grain to the specified stream.

Parameters

managerIStreamSubscriptionManager: The manager.
grainFactoryIGrainFactory: The grain factory.
streamIdStreamId: The stream identifier.
streamProviderNamestring: Name of the stream provider.
primaryKeylong: The grain's primary key.
grainClassNamePrefixstring: The grain class name prefix.

Returns

The newly added subscription.

AddSubscription(IStreamSubscriptionManager, IGrainFactory, StreamId, string, long, string, string)

staticextension

View source

public static Task<StreamSubscription> AddSubscription<TGrainInterface>(this IStreamSubscriptionManager manager, IGrainFactory grainFactory, StreamId streamId, string streamProviderName, long primaryKey, string keyExtension, string grainClassNamePrefix = null)

Subscribes the specified grain to the specified stream.

Parameters

managerIStreamSubscriptionManager: The manager.
grainFactoryIGrainFactory: The grain factory.
streamIdStreamId: The stream identifier.
streamProviderNamestring: Name of the stream provider.
primaryKeylong: The grain's primary key.
keyExtensionstring: The grain's key extension.
grainClassNamePrefixstring: The grain class name prefix.

Returns

The newly added subscription.

AddSubscription(IStreamSubscriptionManager, IGrainFactory, StreamId, string, string, string)

staticextension

View source

public static Task<StreamSubscription> AddSubscription<TGrainInterface>(this IStreamSubscriptionManager manager, IGrainFactory grainFactory, StreamId streamId, string streamProviderName, string primaryKey, string grainClassNamePrefix = null)

Subscribes the specified grain to the specified stream.

Parameters

managerIStreamSubscriptionManager: The manager.
grainFactoryIGrainFactory: The grain factory.
streamIdStreamId: The stream identifier.
streamProviderNamestring: Name of the stream provider.
primaryKeystring: The grain's primary key.
grainClassNamePrefixstring: The grain class name prefix.

Returns

The newly added subscription.

TryGetStreamSubscriptionManager(IStreamProvider, IStreamSubscriptionManager)

staticextension

View source

public static bool TryGetStreamSubscriptionManager(this IStreamProvider streamProvider, out IStreamSubscriptionManager manager)

Returns the IStreamSubscriptionManager for the provided stream provider.

Parameters

streamProviderIStreamProvider: The stream provider.
managerIStreamSubscriptionManager: The manager.

Returns

true if the stream subscription manager could be retrieved, false otherwise.