Skip to content

IStreamPubSub.RegisterConsumer(GuidId, QualifiedStreamId, GrainId, string?, CancellationToken)

RegisterConsumer(GuidId, QualifiedStreamId, GrainId, string?, CancellationToken)

virtual
View source
public virtual Task RegisterConsumer(GuidId subscriptionId, QualifiedStreamId streamId, GrainId streamConsumer, string? filterData, CancellationToken cancellationToken)
Registers a stream consumer.

Parameters

subscriptionIdGuidId
The subscription identifier.
streamIdQualifiedStreamId
The stream identifier.
streamConsumerGrainId
The consumer identifier.
filterDatastring?
The optional filter data.
cancellationTokenCancellationToken
The cancellation token.

Returns

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