StreamSubscriptionHandle<T> 类

定义

命名空间:

Orleans.Streams

程序集:

Orleans.Streaming.dll

包:

Microsoft.Orleans.Streaming v8.2.0

表示此订阅的句柄。 使用者可以序列化和存储句柄，以便稍后取消订阅，例如在此粒度上的另一个激活中。

[System.Serializable]
[Orleans.GenerateSerializer]
public abstract class StreamSubscriptionHandle<T> : IEquatable<Orleans.Streams.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))

类型参数

T

继承

Object

StreamSubscriptionHandle<T>

属性

SerializableAttribute GenerateSerializerAttribute

实现

IEquatable<StreamSubscriptionHandle<T>>

构造函数

StreamSubscriptionHandle<T>()

表示此订阅的句柄。 使用者可以序列化和存储句柄，以便稍后取消订阅，例如在此粒度上的另一个激活中。

属性

HandleId	获取此 StreamSubscriptionHandle 的唯一标识符
ProviderName	获取提供程序的名称。
StreamId	获取流标识符。

方法

Equals(StreamSubscriptionHandle<T>)	表示此订阅的句柄。 使用者可以序列化和存储句柄，以便稍后取消订阅，例如在此粒度上的另一个激活中。
ResumeAsync(IAsyncBatchObserver<T>, StreamSequenceToken)	将订阅的批处理消耗恢复为流。
ResumeAsync(IAsyncObserver<T>, StreamSequenceToken)	从订阅恢复对流的使用。
UnsubscribeAsync()	取消订阅此可观测对象的流使用者。

扩展方法

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)	如果提供的流筛选器函数不适合，则引发。 通常是因为它不是静态方法。
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken)	使用委托继续使用流。 此方法是 StreamSubscriptionHandle.ResumeAsync 的帮助程序，允许订阅类内联处理程序方法，而无需 IAsyncObserver 实例。
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)	使用委托继续使用流。 此方法是 StreamSubscriptionHandle.ResumeAsync 的帮助程序，允许订阅类内联处理程序方法，而无需 IAsyncObserver 实例。
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken)	使用委托继续使用流。 此方法是 StreamSubscriptionHandle.ResumeAsync 的帮助程序，允许订阅类内联处理程序方法，而无需 IAsyncObserver 实例。
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, StreamSequenceToken)	如果提供的流筛选器函数不适合，则引发。 通常是因为它不是静态方法。
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, StreamSequenceToken)	使用委托继续使用流。 此方法是 StreamSubscriptionHandle.ResumeAsync 的帮助程序，允许订阅类内联处理程序方法，而无需 IAsyncBatchObserver 的实例。
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)	使用委托继续使用流。 此方法是 StreamSubscriptionHandle.ResumeAsync 的帮助程序，允许订阅类内联处理程序方法，而无需 IAsyncBatchObserver 的实例。
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Task>, StreamSequenceToken)	使用委托继续使用流。 此方法是 StreamSubscriptionHandle.ResumeAsync 的帮助程序，允许订阅类内联处理程序方法，而无需 IAsyncBatchObserver 的实例。