Edit

Share via


StreamSubscriptionHandle<T> Class

Definition

Handle representing this subscription. Consumer may serialize and store the handle in order to unsubscribe later, for example in another activation on this grain.

[System.Serializable]
public abstract class StreamSubscriptionHandle<T> : IEquatable<Orleans.Streams.StreamSubscriptionHandle<T>>
[System.Serializable]
[Orleans.GenerateSerializer]
public abstract class StreamSubscriptionHandle<T> : IEquatable<Orleans.Streams.StreamSubscriptionHandle<T>>
[<System.Serializable>]
type StreamSubscriptionHandle<'T> = class
    interface IEquatable<StreamSubscriptionHandle<'T>>
[<System.Serializable>]
[<Orleans.GenerateSerializer>]
type StreamSubscriptionHandle<'T> = class
    interface IEquatable<StreamSubscriptionHandle<'T>>
Public MustInherit Class StreamSubscriptionHandle(Of T)
Implements IEquatable(Of StreamSubscriptionHandle(Of T))

Type Parameters

T
Inheritance
StreamSubscriptionHandle<T>
Attributes
Implements

Constructors

StreamSubscriptionHandle<T>()

Properties

HandleId

Gets the unique identifier for this StreamSubscriptionHandle

ProviderName

Gets the name of the provider.

StreamId

Gets the stream identifier.

StreamIdentity

Methods

Equals(StreamSubscriptionHandle<T>)

Indicates whether the current object is equal to another object of the same type.

ResumeAsync(IAsyncBatchObserver<T>, StreamSequenceToken)

Resume batch consumption from a subscription to a stream.

ResumeAsync(IAsyncObserver<T>, StreamSequenceToken)

Resumed consumption from a subscription to a stream.

UnsubscribeAsync()

Unsubscribe a stream consumer from this observable.

Extension Methods

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)

Thrown if the supplied stream filter function is not suitable. Usually this is because it is not a static method.

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken)

Resumes consumption of a stream using delegates. This method is a helper for the StreamSubscriptionHandle.ResumeAsync allowing the subscribing class to inline the handler methods instead of requiring an instance of IAsyncObserver.

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)

Resumes consumption of a stream using delegates. This method is a helper for the StreamSubscriptionHandle.ResumeAsync allowing the subscribing class to inline the handler methods instead of requiring an instance of IAsyncObserver.

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken)

Resumes consumption of a stream using delegates. This method is a helper for the StreamSubscriptionHandle.ResumeAsync allowing the subscribing class to inline the handler methods instead of requiring an instance of IAsyncObserver.

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, StreamSequenceToken)

Thrown if the supplied stream filter function is not suitable. Usually this is because it is not a static method.

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, StreamSequenceToken)

Resumes consumption of a stream using delegates. This method is a helper for the StreamSubscriptionHandle.ResumeAsync allowing the subscribing class to inline the handler methods instead of requiring an instance of IAsyncBatchObserver.

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)

Resumes consumption of a stream using delegates. This method is a helper for the StreamSubscriptionHandle.ResumeAsync allowing the subscribing class to inline the handler methods instead of requiring an instance of IAsyncBatchObserver.

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Task>, StreamSequenceToken)

Resumes consumption of a stream using delegates. This method is a helper for the StreamSubscriptionHandle.ResumeAsync allowing the subscribing class to inline the handler methods instead of requiring an instance of IAsyncBatchObserver.

Applies to