IStreamPubSub
interface
Namespace: Orleans.Streams
public interface IStreamPubSubMethods
ConsumerCount(QualifiedStreamId)CreateSubscriptionId(QualifiedStreamId, GrainId)FaultSubscription(QualifiedStreamId, GuidId)GetAllSubscriptions(QualifiedStreamId, GrainId)ProducerCount(QualifiedStreamId)RegisterConsumer(GuidId, QualifiedStreamId, GrainId, string)RegisterProducer(QualifiedStreamId, GrainId)UnregisterConsumer(GuidId, QualifiedStreamId)UnregisterProducer(QualifiedStreamId, GrainId)
