Skip to content

IStreamSubscriptionObserver Methods

When implemented by a grain, notifies the grain of any new or resuming subscriptions. Stateless worker grains receive this notification on each activation so that every activation can attach its own observer.

OnSubscribed(IStreamSubscriptionHandleFactory)

abstract
public abstract Task OnSubscribed(IStreamSubscriptionHandleFactory handleFactory)
Called when this grain receives a message for a stream which it has not yet explicitly subscribed to or resumed.

Parameters

handleFactoryIStreamSubscriptionHandleFactory
The handle factory.

Returns

A System.Threading.Tasks.Task representing the operation.