Skip to content

IStreamPubSub.RegisterProducer(QualifiedStreamId, GrainId)

RegisterProducer(QualifiedStreamId, GrainId)

abstract
View source
public abstract Task<ISet<PubSubSubscriptionState>> RegisterProducer(QualifiedStreamId streamId, GrainId streamProducer)
Registers a producer for a stream and returns the active consumer registrations which the producer should connect to.

Parameters

streamIdQualifiedStreamId
The qualified stream identifier.
streamProducerGrainId
The identifier of the producer.

Returns

The active consumer registrations for the stream.