Skip to content

IStreamPubSub.RegisterProducer(QualifiedStreamId, GrainId, CancellationToken)

RegisterProducer(QualifiedStreamId, GrainId, CancellationToken)

virtual
View source
public virtual Task<ISet<PubSubSubscriptionState>> RegisterProducer(QualifiedStreamId streamId, GrainId streamProducer, CancellationToken cancellationToken)
Registers a stream producer.

Parameters

streamIdQualifiedStreamId
The stream identifier.
streamProducerGrainId
The producer identifier.
cancellationTokenCancellationToken
The cancellation token.

Returns

The set of stream subscriptions.