AsyncObservableExtensions.SubscribeAsync Метод

Ссылка

Определение

Пространство имен:: Orleans.Streams

Сборка:: Orleans.dll

Сборка:: Orleans.Core.Abstractions.dll

Сборка:: Orleans.Streaming.dll

Пакет:: Microsoft.Orleans.Core v1.5.10

Пакет:: Microsoft.Orleans.Core.Abstractions v2.4.5

Пакет:: Microsoft.Orleans.Core.Abstractions v3.6.5

Пакет:: Microsoft.Orleans.Streaming v7.2.5

Пакет:: Microsoft.Orleans.Streaming v8.0.0

Пакет:: Microsoft.Orleans.Streaming v8.1.0

Пакет:: Microsoft.Orleans.Streaming v8.2.0

Важно!

Некоторые сведения относятся к предварительной версии продукта, в которую до выпуска могут быть внесены существенные изменения. Майкрософт не предоставляет никаких гарантий, явных или подразумеваемых, относительно приведенных здесь сведений.

Перегрузки

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>)	Подпишите потребителя на этот наблюдаемый объект с помощью делегатов. Этот метод является вспомогательным для IAsyncObservable.SubscribeAsync, позволяя подписывающемуся классу встраивать методы обработчика вместо того, чтобы требовать экземпляр IAsyncObserver.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)	Подпишите потребителя на этот наблюдаемый объект с помощью делегатов. Этот метод является вспомогательным для IAsyncObservable.SubscribeAsync, позволяя подписывающемуся классу встраивать методы обработчика вместо того, чтобы требовать экземпляр IAsyncObserver.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>)	Подпишите потребителя на этот наблюдаемый объект с помощью делегатов. Этот метод является вспомогательным для IAsyncObservable.SubscribeAsync, позволяя подписывающемуся классу встраивать методы обработчика вместо того, чтобы требовать экземпляр IAsyncObserver.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>)	Подпишите потребителя на этот наблюдаемый объект с помощью делегатов. Этот метод является вспомогательным для IAsyncObservable.SubscribeAsync, позволяя подписывающемуся классу встраивать методы обработчика вместо того, чтобы требовать экземпляр IAsyncObserver.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken)	Подпишите потребителя на этот наблюдаемый объект с помощью делегатов. Этот метод является вспомогательным для IAsyncObservable.SubscribeAsync, позволяя подписывающемуся классу встраивать методы обработчика вместо того, чтобы требовать экземпляр IAsyncObserver.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>)	Подпишите потребителя на этот наблюдаемый объект с помощью делегатов. Этот метод является вспомогательным для IAsyncObservable.SubscribeAsync, позволяя подписывающемуся классу встраивать методы обработчика вместо того, чтобы требовать экземпляр IAsyncObserver.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken)	Подпишите потребителя на этот наблюдаемый объект с помощью делегатов. Этот метод является вспомогательным для IAsyncObservable.SubscribeAsync, позволяя подписывающемуся классу встраивать методы обработчика вместо того, чтобы требовать экземпляр IAsyncObserver.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken, StreamFilterPredicate, Object)	Подпишите потребителя на этот наблюдаемый объект с помощью делегатов. Этот метод является вспомогательным для IAsyncObservable.SubscribeAsync, позволяя подписывающемуся классу встраивать методы обработчика вместо того, чтобы требовать экземпляр IAsyncObserver.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)	Подпишите потребителя на этот наблюдаемый объект с помощью делегатов. Этот метод является вспомогательным для IAsyncObservable.SubscribeAsync, позволяя подписывающемуся классу встраивать методы обработчика вместо того, чтобы требовать экземпляр IAsyncObserver.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken, StreamFilterPredicate, Object)	Подпишите потребителя на этот наблюдаемый объект с помощью делегатов. Этот метод является вспомогательным для IAsyncObservable.SubscribeAsync, позволяя подписывающемуся классу встраивать методы обработчика вместо того, чтобы требовать экземпляр IAsyncObserver.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object)	Подпишите потребителя на этот наблюдаемый объект с помощью делегатов. Этот метод является вспомогательным для IAsyncObservable.SubscribeAsync, позволяя подписывающемуся классу встраивать методы обработчика вместо того, чтобы требовать экземпляр IAsyncObserver.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken, Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object)	Подпишите потребителя на этот наблюдаемый объект с помощью делегатов. Этот метод является вспомогательным для IAsyncObservable.SubscribeAsync, позволяя подписывающемуся классу встраивать методы обработчика вместо того, чтобы требовать экземпляр IAsyncObserver.

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>)

Исходный код:: AsyncObservableExtensions.cs

Подпишите потребителя на этот наблюдаемый объект с помощью делегатов. Этот метод является вспомогательным для IAsyncObservable.SubscribeAsync, позволяя подписывающемуся классу встраивать методы обработчика вместо того, чтобы требовать экземпляр IAsyncObserver.

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync);

static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>

<Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task)) As Task(Of StreamSubscriptionHandle(Of T))

Параметры типа

T

Тип объекта, создаваемого наблюдаемым объектом.

Параметры

obs: IAsyncObservable<T>

Объект Observable.

onNextAsync: Func<T,StreamSequenceToken,Task>

Делегат, который вызывается для IAsyncObserver.OnNextAsync.

Возвращаемое значение

Task<StreamSubscriptionHandle<T>>

Обещание для StreamSubscriptionHandle, представляющего подписку. Потребитель может отменить подписку с помощью этого дескриптора. Подписка остается активной до тех пор, пока она не отменена явным образом.

Применяется к

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Orleans.Streams.StreamSequenceToken token);

static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>

<Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), token As StreamSequenceToken) As Task(Of StreamSubscriptionHandle(Of T))

Параметры типа

T

Тип объекта, создаваемого наблюдаемым объектом.

Параметры

obs: IAsyncObservable<T>

Объект Observable.

onNextAsync: Func<T,StreamSequenceToken,Task>

Делегат, который вызывается для IAsyncObserver.OnNextAsync.

token: StreamSequenceToken

Последовательность потоков, используемая в качестве смещения для запуска подписки.

Возвращаемое значение

Task<StreamSubscriptionHandle<T>>

Исключения

ArgumentException

Возникает, если предоставленная функция фильтра потока не подходит. Обычно это связано с тем, что это не статический метод.

Применяется к

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>)

Исходный код:: AsyncObservableExtensions.cs

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync);

static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>

<Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task)) As Task(Of StreamSubscriptionHandle(Of T))

Параметры типа

T

Тип объекта, создаваемого наблюдаемым объектом.

Параметры

obs: IAsyncObservable<T>

Объект Observable.

onNextAsync: Func<T,StreamSequenceToken,Task>

Делегат, который вызывается для IAsyncObserver.OnNextAsync.

onErrorAsync: Func<Exception,Task>

Делегат, вызываемой для IAsyncObserver.OnErrorAsync.

Возвращаемое значение

Task<StreamSubscriptionHandle<T>>

Применяется к

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>)

Исходный код:: AsyncObservableExtensions.cs

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<System.Threading.Tasks.Task> onCompletedAsync);

static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>

<Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onCompletedAsync As Func(Of Task)) As Task(Of StreamSubscriptionHandle(Of T))

Параметры типа

T

Тип объекта, создаваемого наблюдаемым объектом.

Параметры

obs: IAsyncObservable<T>

Объект Observable.

onNextAsync: Func<T,StreamSequenceToken,Task>

Делегат, который вызывается для IAsyncObserver.OnNextAsync.

onCompletedAsync: Func<Task>

Делегат, вызываемый для IAsyncObserver.OnCompletedAsync.

Возвращаемое значение

Task<StreamSubscriptionHandle<T>>

Применяется к

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken)

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Orleans.Streams.StreamSequenceToken token);

static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'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 SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task), token As StreamSequenceToken) As Task(Of StreamSubscriptionHandle(Of T))

Параметры типа

T

Тип объекта, создаваемого наблюдаемым объектом.

Параметры

obs: IAsyncObservable<T>

Объект Observable.

onNextAsync: Func<T,StreamSequenceToken,Task>

Делегат, который вызывается для IAsyncObserver.OnNextAsync.

onErrorAsync: Func<Exception,Task>

Делегат, вызываемой для IAsyncObserver.OnErrorAsync.

token: StreamSequenceToken

Последовательность потоков, используемая в качестве смещения для запуска подписки.

Возвращаемое значение

Task<StreamSubscriptionHandle<T>>

Исключения

ArgumentException

Применяется к

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>)

Исходный код:: AsyncObservableExtensions.cs

Подпишите потребителя на этот наблюдаемый объект с помощью делегатов. Этот метод является вспомогательным для IAsyncObservable.SubscribeAsync, позволяя подписывающему классу встраивать методы обработчика вместо того, чтобы требовать экземпляр IAsyncObserver.

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Func<System.Threading.Tasks.Task> onCompletedAsync);

static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>

<Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task), onCompletedAsync As Func(Of Task)) As Task(Of StreamSubscriptionHandle(Of T))

Параметры типа

T

Тип объекта, создаваемого наблюдаемым объектом.

Параметры

obs: IAsyncObservable<T>

Объект Observable.

onNextAsync: Func<T,StreamSequenceToken,Task>

Делегат, который вызывается для IAsyncObserver.OnNextAsync.

onErrorAsync: Func<Exception,Task>

Делегат, вызываемой для IAsyncObserver.OnErrorAsync.

onCompletedAsync: Func<Task>

Делегат, вызываемый для IAsyncObserver.OnCompletedAsync.

Возвращаемое значение

Task<StreamSubscriptionHandle<T>>

Применяется к

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken)

Подпишите потребителя на этот наблюдаемый объект с помощью делегатов. Этот метод является вспомогательным для IAsyncObservable.SubscribeAsync, позволяя подписывающему классу встраивать методы обработчика вместо того, чтобы требовать экземпляр IAsyncObserver.

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<System.Threading.Tasks.Task> onCompletedAsync, Orleans.Streams.StreamSequenceToken token);

static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'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 SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onCompletedAsync As Func(Of Task), token As StreamSequenceToken) As Task(Of StreamSubscriptionHandle(Of T))

Параметры типа

T

Тип объекта, создаваемого наблюдаемым объектом.

Параметры

obs: IAsyncObservable<T>

Наблюдаемый объект.

onNextAsync: Func<T,StreamSequenceToken,Task>

Делегат, который вызывается для IAsyncObserver.OnNextAsync.

onCompletedAsync: Func<Task>

Делегат, вызываемый для IAsyncObserver.OnCompletedAsync.

token: StreamSequenceToken

Последовательность потока, используемая в качестве смещения для запуска подписки.

Возвращаемое значение

Task<StreamSubscriptionHandle<T>>

Исключения

ArgumentException

Возникает, если предоставленная функция фильтра потока не подходит. Обычно это происходит потому, что это не статический метод.

Применяется к

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken, StreamFilterPredicate, Object)

Исходный код:: AsyncObservableExtensions.cs

Подпишите потребителя на этот наблюдаемый объект с помощью делегатов. Этот метод является вспомогательным для IAsyncObservable.SubscribeAsync, позволяя подписывающему классу встраивать методы обработчика вместо того, чтобы требовать экземпляр IAsyncObserver.

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Orleans.Streams.StreamSequenceToken token, Orleans.Streams.StreamFilterPredicate filterFunc = default, object filterData = default);

static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken * Orleans.Streams.StreamFilterPredicate * obj -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>

<Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), token As StreamSequenceToken, Optional filterFunc As StreamFilterPredicate = Nothing, Optional filterData As Object = Nothing) As Task(Of StreamSubscriptionHandle(Of T))

Параметры типа

T

Тип объекта, создаваемого наблюдаемым объектом.

Параметры

obs: IAsyncObservable<T>

Наблюдаемый объект.

onNextAsync: Func<T,StreamSequenceToken,Task>

Делег, вызываемая для IAsyncObserver.OnNextAsync.

token: StreamSequenceToken

Последовательность потока, используемая в качестве смещения для запуска подписки.

filterFunc: StreamFilterPredicate

Фильтр, применяемый для этой подписки

filterData: Object

Объект данных, который будет передан в filterFunc. Обычно он содержит все параметры, необходимые filterFunc для принятия решения о фильтрации.

Возвращаемое значение

Task<StreamSubscriptionHandle<T>>

Исключения

ArgumentException

Применяется к

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)

Подпишите потребителя на этот наблюдаемый объект с помощью делегатов. Этот метод является вспомогательным для IAsyncObservable.SubscribeAsync, позволяя подписывающему классу встраивать методы обработчика вместо того, чтобы требовать экземпляр IAsyncObserver.

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, 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);

static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'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 SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task), onCompletedAsync As Func(Of Task), token As StreamSequenceToken) As Task(Of StreamSubscriptionHandle(Of T))

Параметры типа

T

Тип объекта, создаваемого наблюдаемым объектом.

Параметры

obs: IAsyncObservable<T>

Наблюдаемый объект.

onNextAsync: Func<T,StreamSequenceToken,Task>

Делегат, который вызывается для IAsyncObserver.OnNextAsync.

onErrorAsync: Func<Exception,Task>

Делегат, который вызывается для IAsyncObserver.OnErrorAsync.

onCompletedAsync: Func<Task>

Делегат, вызываемый для IAsyncObserver.OnCompletedAsync.

token: StreamSequenceToken

Последовательность потока, используемая в качестве смещения для запуска подписки.

Возвращаемое значение

Task<StreamSubscriptionHandle<T>>

Исключения

ArgumentException

Применяется к

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken, StreamFilterPredicate, Object)

Исходный код:: AsyncObservableExtensions.cs

Подпишите потребителя на этот наблюдаемый объект с помощью делегатов. Этот метод является вспомогательным для IAsyncObservable.SubscribeAsync, позволяя подписывающему классу встраивать методы обработчика вместо того, чтобы требовать экземпляр IAsyncObserver.

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Orleans.Streams.StreamSequenceToken token, Orleans.Streams.StreamFilterPredicate filterFunc = default, object filterData = default);

static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken * Orleans.Streams.StreamFilterPredicate * obj -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>

<Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task), token As StreamSequenceToken, Optional filterFunc As StreamFilterPredicate = Nothing, Optional filterData As Object = Nothing) As Task(Of StreamSubscriptionHandle(Of T))

Параметры типа

T

Тип объекта, создаваемого наблюдаемым объектом.

Параметры

obs: IAsyncObservable<T>

Наблюдаемый объект.

onNextAsync: Func<T,StreamSequenceToken,Task>

Делег, вызываемая для IAsyncObserver.OnNextAsync.

onErrorAsync: Func<Exception,Task>

Делег, вызываемая для IAsyncObserver.OnErrorAsync.

token: StreamSequenceToken

Последовательность потока, используемая в качестве смещения для запуска подписки.

filterFunc: StreamFilterPredicate

Фильтр, применяемый для этой подписки

filterData: Object

Возвращаемое значение

Task<StreamSubscriptionHandle<T>>

Исключения

ArgumentException

Применяется к

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object)

Исходный код:: AsyncObservableExtensions.cs

Подпишите потребителя на этот наблюдаемый объект с помощью делегатов. Этот метод является вспомогательным для IAsyncObservable.SubscribeAsync, позволяя подписывающему классу встраивать методы обработчика вместо того, чтобы требовать экземпляр IAsyncObserver.

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<System.Threading.Tasks.Task> onCompletedAsync, Orleans.Streams.StreamSequenceToken token, Orleans.Streams.StreamFilterPredicate filterFunc = default, object filterData = default);

static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken * Orleans.Streams.StreamFilterPredicate * obj -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>

<Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onCompletedAsync As Func(Of Task), token As StreamSequenceToken, Optional filterFunc As StreamFilterPredicate = Nothing, Optional filterData As Object = Nothing) As Task(Of StreamSubscriptionHandle(Of T))

Параметры типа

T

Тип объекта, создаваемого наблюдаемым объектом.

Параметры

obs: IAsyncObservable<T>

Наблюдаемый объект.

onNextAsync: Func<T,StreamSequenceToken,Task>

Делег, вызываемая для IAsyncObserver.OnNextAsync.

onCompletedAsync: Func<Task>

Делег, вызываемый для IAsyncObserver.OnCompletedAsync.

token: StreamSequenceToken

Последовательность потока, используемая в качестве смещения для запуска подписки.

filterFunc: StreamFilterPredicate

Фильтр, применяемый для этой подписки

filterData: Object

Возвращаемое значение

Task<StreamSubscriptionHandle<T>>

Исключения

ArgumentException

Применяется к

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken, Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object)

Исходный код:: AsyncObservableExtensions.cs

Подпишите потребителя на этот наблюдаемый объект с помощью делегатов. Этот метод является вспомогательным для IAsyncObservable.SubscribeAsync, позволяя подписывающему классу встраивать методы обработчика вместо того, чтобы требовать экземпляр IAsyncObserver.

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, 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, Orleans.Streams.StreamFilterPredicate filterFunc = default, object filterData = default);

static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken * Orleans.Streams.StreamFilterPredicate * obj -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>

<Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task), onCompletedAsync As Func(Of Task), token As StreamSequenceToken, Optional filterFunc As StreamFilterPredicate = Nothing, Optional filterData As Object = Nothing) As Task(Of StreamSubscriptionHandle(Of T))

Параметры типа

T

Тип объекта, создаваемого наблюдаемым объектом.

Параметры

obs: IAsyncObservable<T>

Наблюдаемый объект.

onNextAsync: Func<T,StreamSequenceToken,Task>

Делег, вызываемая для IAsyncObserver.OnNextAsync.

onErrorAsync: Func<Exception,Task>

Делег, вызываемая для IAsyncObserver.OnErrorAsync.

onCompletedAsync: Func<Task>

Делег, вызываемый для IAsyncObserver.OnCompletedAsync.

token: StreamSequenceToken

Последовательность потока, используемая в качестве смещения для запуска подписки.

filterFunc: StreamFilterPredicate

Фильтр, применяемый для этой подписки

filterData: Object

Возвращаемое значение

Task<StreamSubscriptionHandle<T>>

Исключения

ArgumentException

Применяется к

Поделиться через

AsyncObservableExtensions.SubscribeAsync Метод

Определение

Перегрузки

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>)

Параметры типа

Параметры

Возвращаемое значение

Применяется к

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)

Параметры типа

Параметры

Возвращаемое значение

Исключения

Применяется к

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>)

Параметры типа

Параметры

Возвращаемое значение

Применяется к

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>)

Параметры типа

Параметры

Возвращаемое значение

Применяется к

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken)

Параметры типа

Параметры

Возвращаемое значение

Исключения

Применяется к

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>)

Параметры типа

Параметры

Возвращаемое значение

Применяется к

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken)

Параметры типа

Параметры

Возвращаемое значение

Исключения

Применяется к

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken, StreamFilterPredicate, Object)

Параметры типа

Параметры

Возвращаемое значение

Исключения

Применяется к

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)

Параметры типа

Параметры

Возвращаемое значение

Исключения

Применяется к

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken, StreamFilterPredicate, Object)

Параметры типа

Параметры

Возвращаемое значение

Исключения

Применяется к

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object)

Параметры типа

Параметры

Возвращаемое значение

Исключения

Применяется к

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken, Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object)

Параметры типа

Параметры

Возвращаемое значение

Исключения

Применяется к

Дополнительные ресурсы