ConsumerCount(QualifiedStreamId)
abstract
public abstract Task<int> ConsumerCount(QualifiedStreamId streamId)Parameters
streamIdQualifiedStreamId
IStreamPubSub Methods
CreateSubscriptionId(QualifiedStreamId, GrainId)
abstract
public abstract GuidId CreateSubscriptionId(QualifiedStreamId streamId, GrainId streamConsumer)Parameters
streamIdQualifiedStreamIdstreamConsumerGrainId
FaultSubscription(QualifiedStreamId, GuidId)
abstract
public abstract Task<bool> FaultSubscription(QualifiedStreamId streamId, GuidId subscriptionId)Parameters
streamIdQualifiedStreamIdsubscriptionIdGuidId
GetAllSubscriptions(QualifiedStreamId, GrainId)
abstract
public abstract Task<List<StreamSubscription>> GetAllSubscriptions(QualifiedStreamId streamId, GrainId streamConsumer = default(GrainId))Parameters
streamIdQualifiedStreamIdstreamConsumerGrainId
ProducerCount(QualifiedStreamId)
abstract
public abstract Task<int> ProducerCount(QualifiedStreamId streamId)Parameters
streamIdQualifiedStreamId
RegisterConsumer(GuidId, QualifiedStreamId, GrainId, string)
abstract
public abstract Task RegisterConsumer(GuidId subscriptionId, QualifiedStreamId streamId, GrainId streamConsumer, string filterData)Parameters
subscriptionIdGuidIdstreamIdQualifiedStreamIdstreamConsumerGrainIdfilterDatastring
RegisterProducer(QualifiedStreamId, GrainId)
abstract
public abstract Task<ISet<PubSubSubscriptionState>> RegisterProducer(QualifiedStreamId streamId, GrainId streamProducer)Parameters
streamIdQualifiedStreamIdstreamProducerGrainId
UnregisterConsumer(GuidId, QualifiedStreamId)
abstract
public abstract Task UnregisterConsumer(GuidId subscriptionId, QualifiedStreamId streamId)Parameters
subscriptionIdGuidIdstreamIdQualifiedStreamId
UnregisterProducer(QualifiedStreamId, GrainId)
abstract
public abstract Task UnregisterProducer(QualifiedStreamId streamId, GrainId streamProducer)Parameters
streamIdQualifiedStreamIdstreamProducerGrainId