PubSubSubscriptionState
class
Namespace: Orleans.Streams
Represents the pub/sub registration state for a stream subscription.
[Orleans.GenerateSerializer]public sealed class PubSubSubscriptionState : IEquatable<PubSubSubscriptionState?>, IJsonOnDeserializedConstructors
PubSubSubscriptionState(GuidId, QualifiedStreamId, GrainId, string?, SubscriptionStates)Initializes a stream subscription registration.PubSubSubscriptionState(GuidId, QualifiedStreamId, GrainId)Initializes an active stream subscription registration.
Properties
IsFaultedGets a value indicating whether the subscription is faulted.
Methods
AddFilter(string?)Sets the serialized filter data associated with the subscription.Equals(GuidId?)Determines whether this subscription has the specified identifier.Equals(PubSubSubscriptionState?)Indicates whether the current object is equal to another object of the same type.Equals(object?)Determines whether the specified object is equal to the current object.FaultMarks the subscription as faulted.GetHashCodeServes as the default hash function.ToStringReturns a string that represents the current object.operator ==(PubSubSubscriptionState?, PubSubSubscriptionState?)Compares two subscription states for equality by subscription identifier.operator !=(PubSubSubscriptionState?, PubSubSubscriptionState?)Compares two subscription states for inequality by subscription identifier.
Fields
ConsumerThe identifier of the grain which consumes the stream.FilterDataThe serialized filter data associated with the subscription.StreamThe qualified identifier of the subscribed stream.SubscriptionIdThe subscription identifier.stateThe lifecycle state of the subscription.
