Share via


StreamSubscriptionHandle<T> 類別

定義

代表此訂用帳戶的控制碼。 取用者可以序列化並儲存控制碼,以便稍後取消訂閱,例如在此細微性上的另一個啟用中。

[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))

類型參數

T
繼承
StreamSubscriptionHandle<T>
屬性
實作

建構函式

StreamSubscriptionHandle<T>()

代表此訂用帳戶的控制碼。 取用者可以序列化並儲存控制碼,以便稍後取消訂閱,例如在此細微性上的另一個啟用中。

屬性

HandleId

取得這個 StreamSubscriptionHandle 的唯一識別碼

ProviderName

取得提供者的名稱。

StreamId

取得資料流程識別碼。

StreamIdentity

代表此訂用帳戶的控制碼。 取用者可以序列化並儲存控制碼,以便稍後取消訂閱,例如在此細微性上的另一個啟用中。

方法

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 的實例。

適用於