StreamSubscriptionHandleExtensions.ResumeAsync Метод
Определение
Важно!
Некоторые сведения относятся к предварительной версии продукта, в которую до выпуска могут быть внесены существенные изменения. Майкрософт не предоставляет никаких гарантий, явных или подразумеваемых, относительно приведенных здесь сведений.
Перегрузки
| ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, StreamSequenceToken) |
Вызывается, если указанная функция фильтра потока не подходит. Обычно это связано с тем, что это не статический метод. |
| ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,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<Task>, StreamSequenceToken) |
Возобновляет использование потока с помощью делегатов. Этот метод является вспомогательным методом для StreamSubscriptionHandle.ResumeAsync, позволяя классу подписки встраивать методы обработчика вместо необходимости экземпляра IAsyncBatchObserver. |
| ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,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>, Func<Exception,Task>, Func<Task>, StreamSequenceToken) |
Возобновляет использование потока с помощью делегатов. Этот метод является вспомогательным методом для StreamSubscriptionHandle.ResumeAsync, позволяя классу подписки встраивать методы обработчика вместо необходимости экземпляра IAsyncBatchObserver. |
| ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken) |
Возобновляет использование потока с помощью делегатов. Этот метод является вспомогательным методом для StreamSubscriptionHandle.ResumeAsync, позволяя классу подписки встраивать методы обработчика вместо необходимости экземпляра IAsyncObserver. |
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, StreamSequenceToken)
- Исходный код:
- StreamSubscriptionHandleExtensions.cs
Вызывается, если указанная функция фильтра потока не подходит. Обычно это связано с тем, что это не статический метод.
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)
- Исходный код:
- StreamSubscriptionHandleExtensions.cs
Вызывается, если указанная функция фильтра потока не подходит. Обычно это связано с тем, что это не статический метод.
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)
- Исходный код:
- StreamSubscriptionHandleExtensions.cs
Возобновляет использование потока с помощью делегатов. Этот метод является вспомогательным методом для 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)
- Исходный код:
- StreamSubscriptionHandleExtensions.cs
Возобновляет использование потока с помощью делегатов. Этот метод является вспомогательным методом для 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)
- Исходный код:
- StreamSubscriptionHandleExtensions.cs
Возобновляет использование потока с помощью делегатов. Этот метод является вспомогательным методом для 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)
- Исходный код:
- StreamSubscriptionHandleExtensions.cs
Возобновляет использование потока с помощью делегатов. Этот метод является вспомогательным методом для 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)
- Исходный код:
- StreamSubscriptionHandleExtensions.cs
Возобновляет использование потока с помощью делегатов. Этот метод является вспомогательным методом для 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)
- Исходный код:
- StreamSubscriptionHandleExtensions.cs
Возобновляет потребление потока с помощью делегатов. Этот метод является вспомогательным для 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, представляющее подписку. Потребитель может отменить подписку с помощью этого дескриптора. Подписка остается активной до тех пор, пока она не будет явно отменена.