StreamSubscriptionHandleExtensions.ResumeAsync 方法
定義
重要
部分資訊涉及發行前產品,在發行之前可能會有大幅修改。 Microsoft 對此處提供的資訊,不做任何明確或隱含的瑕疵擔保。
多載
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, StreamSequenceToken)
如果提供的資料流程篩選函式不適合,則會擲回 。 這通常是因為它不是靜態方法。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> ResumeAsync<T> (this Orleans.Streams.StreamSubscriptionHandle<T> handle, Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<T>>,System.Threading.Tasks.Task> onNextAsync, Orleans.Streams.StreamSequenceToken token = default);
static member ResumeAsync : Orleans.Streams.StreamSubscriptionHandle<'T> * Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<'T>>, System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>
<Extension()>
Public Function ResumeAsync(Of T) (handle As StreamSubscriptionHandle(Of T), onNextAsync As Func(Of IList(Of SequentialItem(Of T)), Task), Optional token As StreamSequenceToken = Nothing) As Task(Of StreamSubscriptionHandle(Of T))
類型參數
- T
可觀察物件所產生的型別。
參數
- handle
- StreamSubscriptionHandle<T>
訂閱控制碼。
- onNextAsync
- Func<IList<SequentialItem<T>>,Task>
針對 IAsyncObserver.OnNextAsync 呼叫的委派。
- token
- StreamSequenceToken
要作為起始訂閱之位移的資料流程序列。
傳回
代表訂用帳戶的 StreamSubscriptionHandle 承諾。 取用者可以使用這個控制碼取消訂閱。 只要訂閱未明確取消訂閱,訂用帳戶就會保持作用中狀態。
適用於
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)
如果提供的資料流程篩選函式不適合,則會擲回 。 這通常是因為它不是靜態方法。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> ResumeAsync<T> (this Orleans.Streams.StreamSubscriptionHandle<T> handle, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Orleans.Streams.StreamSequenceToken token = default);
static member ResumeAsync : Orleans.Streams.StreamSubscriptionHandle<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>
<Extension()>
Public Function ResumeAsync(Of T) (handle As StreamSubscriptionHandle(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), Optional token As StreamSequenceToken = Nothing) As Task(Of StreamSubscriptionHandle(Of T))
類型參數
- T
可觀察物件所產生的型別。
參數
- handle
- StreamSubscriptionHandle<T>
訂閱控制碼。
- onNextAsync
- Func<T,StreamSequenceToken,Task>
針對 IAsyncObserver.OnNextAsync 呼叫的委派。
- token
- StreamSequenceToken
要作為起始訂閱之位移的資料流程序列。
傳回
代表訂用帳戶的 StreamSubscriptionHandle 承諾。 取用者可以使用這個控制碼取消訂閱。 只要訂閱未明確取消訂閱,訂用帳戶就會保持作用中狀態。
適用於
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, StreamSequenceToken)
使用委派繼續取用資料流程。 這個方法是 StreamSubscriptionHandle.ResumeAsync 的協助程式,可讓訂閱類別內嵌處理常式方法,而不需要 IAsyncBatchObserver 的實例。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> ResumeAsync<T> (this Orleans.Streams.StreamSubscriptionHandle<T> handle, Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<T>>,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Orleans.Streams.StreamSequenceToken token = default);
static member ResumeAsync : Orleans.Streams.StreamSubscriptionHandle<'T> * Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<'T>>, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>
<Extension()>
Public Function ResumeAsync(Of T) (handle As StreamSubscriptionHandle(Of T), onNextAsync As Func(Of IList(Of SequentialItem(Of T)), Task), onErrorAsync As Func(Of Exception, Task), Optional token As StreamSequenceToken = Nothing) As Task(Of StreamSubscriptionHandle(Of T))
類型參數
- T
可觀察物件所產生的型別。
參數
- handle
- StreamSubscriptionHandle<T>
訂閱控制碼。
- onNextAsync
- Func<IList<SequentialItem<T>>,Task>
針對 IAsyncObserver.OnNextAsync 呼叫的委派。
- token
- StreamSequenceToken
要作為起始訂閱之位移的資料流程序列。
傳回
代表訂用帳戶的 StreamSubscriptionHandle 承諾。 取用者可以使用這個控制碼取消訂閱。 只要訂閱未明確取消訂閱,訂用帳戶就會保持作用中狀態。
適用於
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Task>, StreamSequenceToken)
使用委派繼續取用資料流程。 這個方法是 StreamSubscriptionHandle.ResumeAsync 的協助程式,可讓訂閱類別內嵌處理常式方法,而不需要 IAsyncBatchObserver 的實例。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> ResumeAsync<T> (this Orleans.Streams.StreamSubscriptionHandle<T> handle, Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<T>>,System.Threading.Tasks.Task> onNextAsync, Func<System.Threading.Tasks.Task> onCompletedAsync, Orleans.Streams.StreamSequenceToken token = default);
static member ResumeAsync : Orleans.Streams.StreamSubscriptionHandle<'T> * Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<'T>>, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>
<Extension()>
Public Function ResumeAsync(Of T) (handle As StreamSubscriptionHandle(Of T), onNextAsync As Func(Of IList(Of SequentialItem(Of T)), Task), onCompletedAsync As Func(Of Task), Optional token As StreamSequenceToken = Nothing) As Task(Of StreamSubscriptionHandle(Of T))
類型參數
- T
可觀察物件所產生的型別。
參數
- handle
- StreamSubscriptionHandle<T>
訂閱控制碼。
- onNextAsync
- Func<IList<SequentialItem<T>>,Task>
針對 IAsyncObserver.OnNextAsync 呼叫的委派。
- token
- StreamSequenceToken
要作為起始訂閱之位移的資料流程序列。
傳回
代表訂用帳戶的 StreamSubscriptionHandle 承諾。 取用者可以使用這個控制碼取消訂閱。 只要訂閱未明確取消訂閱,訂用帳戶就會保持作用中狀態。
適用於
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken)
使用委派繼續取用資料流程。 這個方法是 StreamSubscriptionHandle.ResumeAsync 的協助程式,可讓訂閱類別內嵌處理常式方法,而不需要 IAsyncObserver 的實例。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> ResumeAsync<T> (this Orleans.Streams.StreamSubscriptionHandle<T> handle, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Orleans.Streams.StreamSequenceToken token = default);
static member ResumeAsync : Orleans.Streams.StreamSubscriptionHandle<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>
<Extension()>
Public Function ResumeAsync(Of T) (handle As StreamSubscriptionHandle(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task), Optional token As StreamSequenceToken = Nothing) As Task(Of StreamSubscriptionHandle(Of T))
類型參數
- T
可觀察物件所產生的型別。
參數
- handle
- StreamSubscriptionHandle<T>
訂閱控制碼。
- onNextAsync
- Func<T,StreamSequenceToken,Task>
針對 IAsyncObserver.OnNextAsync 呼叫的委派。
- token
- StreamSequenceToken
要作為起始訂閱之位移的資料流程序列。
傳回
代表訂用帳戶的 StreamSubscriptionHandle 承諾。 取用者可以使用這個控制碼取消訂閱。 只要訂閱未明確取消訂閱,訂用帳戶就會保持作用中狀態。
適用於
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken)
使用委派繼續取用資料流程。 這個方法是 StreamSubscriptionHandle.ResumeAsync 的協助程式,可讓訂閱類別內嵌處理常式方法,而不需要 IAsyncObserver 的實例。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> ResumeAsync<T> (this Orleans.Streams.StreamSubscriptionHandle<T> handle, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<System.Threading.Tasks.Task> onCompletedAsync, Orleans.Streams.StreamSequenceToken token = default);
static member ResumeAsync : Orleans.Streams.StreamSubscriptionHandle<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>
<Extension()>
Public Function ResumeAsync(Of T) (handle As StreamSubscriptionHandle(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onCompletedAsync As Func(Of Task), Optional token As StreamSequenceToken = Nothing) As Task(Of StreamSubscriptionHandle(Of T))
類型參數
- T
可觀察物件所產生的型別。
參數
- handle
- StreamSubscriptionHandle<T>
訂閱控制碼。
- onNextAsync
- Func<T,StreamSequenceToken,Task>
針對 IAsyncObserver.OnNextAsync 呼叫的委派。
- token
- StreamSequenceToken
要作為起始訂閱之位移的資料流程序列。
傳回
代表訂用帳戶的 StreamSubscriptionHandle 承諾。 取用者可以使用這個控制碼取消訂閱。 只要訂閱未明確取消訂閱,訂用帳戶就會保持作用中狀態。
適用於
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)
使用委派繼續取用資料流程。 這個方法是 StreamSubscriptionHandle.ResumeAsync 的協助程式,可讓訂閱類別內嵌處理常式方法,而不需要 IAsyncBatchObserver 的實例。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> ResumeAsync<T> (this Orleans.Streams.StreamSubscriptionHandle<T> handle, Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<T>>,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Func<System.Threading.Tasks.Task> onCompletedAsync, Orleans.Streams.StreamSequenceToken token = default);
static member ResumeAsync : Orleans.Streams.StreamSubscriptionHandle<'T> * Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<'T>>, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>
<Extension()>
Public Function ResumeAsync(Of T) (handle As StreamSubscriptionHandle(Of T), onNextAsync As Func(Of IList(Of SequentialItem(Of T)), Task), onErrorAsync As Func(Of Exception, Task), onCompletedAsync As Func(Of Task), Optional token As StreamSequenceToken = Nothing) As Task(Of StreamSubscriptionHandle(Of T))
類型參數
- T
可觀察物件所產生的型別。
參數
- handle
- StreamSubscriptionHandle<T>
訂閱控制碼。
- onNextAsync
- Func<IList<SequentialItem<T>>,Task>
針對 IAsyncObserver.OnNextAsync 呼叫的委派。
- token
- StreamSequenceToken
要作為起始訂閱之位移的資料流程序列。
傳回
代表訂用帳戶的 StreamSubscriptionHandle 承諾。 取用者可以使用這個控制碼取消訂閱。 只要訂閱未明確取消訂閱,訂用帳戶就會保持作用中狀態。
適用於
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)
使用委派繼續取用資料流程。 這個方法是 StreamSubscriptionHandle.ResumeAsync 的協助程式,可讓訂閱類別內嵌處理常式方法,而不需要 IAsyncObserver 的實例。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> ResumeAsync<T> (this Orleans.Streams.StreamSubscriptionHandle<T> handle, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Func<System.Threading.Tasks.Task> onCompletedAsync, Orleans.Streams.StreamSequenceToken token = default);
static member ResumeAsync : Orleans.Streams.StreamSubscriptionHandle<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>
<Extension()>
Public Function ResumeAsync(Of T) (handle As StreamSubscriptionHandle(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task), onCompletedAsync As Func(Of Task), Optional token As StreamSequenceToken = Nothing) As Task(Of StreamSubscriptionHandle(Of T))
類型參數
- T
可觀察物件所產生的型別。
參數
- handle
- StreamSubscriptionHandle<T>
訂閱控制碼。
- onNextAsync
- Func<T,StreamSequenceToken,Task>
針對 IAsyncObserver.OnNextAsync 呼叫的委派。
- token
- StreamSequenceToken
要作為起始訂閱之位移的資料流程序列。
傳回
代表訂用帳戶的 StreamSubscriptionHandle 承諾。 取用者可以使用這個控制碼取消訂閱。 只要訂閱未明確取消訂閱,訂用帳戶就會保持作用中狀態。