AsyncBatchObservableExtensions.SubscribeAsync Metodo

Definizione

Spazio dei nomi:

Orleans.Streams

Assembly:

Orleans.Streaming.dll

Pacchetto:

Microsoft.Orleans.Streaming v8.2.0

Overload

SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>)	Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncBatchObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncBatchObserver.
SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>)	Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncBatchObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncBatchObserver.
SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Task>)	Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncBatchObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncBatchObserver.
SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, Func<Task>)	Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncBatchObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncBatchObserver.

SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>)

Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncBatchObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncBatchObserver.

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncBatchObservable<T> obs, Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<T>>,System.Threading.Tasks.Task> onNextAsync);

static member SubscribeAsync : Orleans.Streams.IAsyncBatchObservable<'T> * Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<'T>>, System.Threading.Tasks.Task> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>

<Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncBatchObservable(Of T), onNextAsync As Func(Of IList(Of SequentialItem(Of T)), Task)) As Task(Of StreamSubscriptionHandle(Of T))

Parametri di tipo

T

Tipo di oggetto prodotto dall'osservabile.

Parametri

obs

IAsyncBatchObservable<T>

Oggetto Observable.

onNextAsync

Func<IList<SequentialItem<T>>,Task>

Delegato chiamato per IAsyncBatchObserver.OnNextAsync.

Restituisce

Task<StreamSubscriptionHandle<T>>

Promessa per un oggetto StreamSubscriptionHandle che rappresenta la sottoscrizione. Il consumer può annullare la sottoscrizione usando questo handle. La sottoscrizione rimane attiva finché non viene annullata in modo esplicito.

SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>)

Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncBatchObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncBatchObserver.

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncBatchObservable<T> obs, Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<T>>,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync);

static member SubscribeAsync : Orleans.Streams.IAsyncBatchObservable<'T> * Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<'T>>, 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 IAsyncBatchObservable(Of T), onNextAsync As Func(Of IList(Of SequentialItem(Of T)), Task), onErrorAsync As Func(Of Exception, Task)) As Task(Of StreamSubscriptionHandle(Of T))

Parametri di tipo

T

Tipo di oggetto prodotto dall'osservabile.

Parametri

obs

IAsyncBatchObservable<T>

Oggetto Observable.

onNextAsync

Func<IList<SequentialItem<T>>,Task>

Delegato chiamato per IAsyncBatchObserver.OnNextAsync.

onErrorAsync

Func<Exception,Task>

Delegato chiamato per IAsyncBatchObserver.OnErrorAsync.

Restituisce

Task<StreamSubscriptionHandle<T>>

Promessa per un oggetto StreamSubscriptionHandle che rappresenta la sottoscrizione. Il consumer può annullare la sottoscrizione usando questo handle. La sottoscrizione rimane attiva finché non viene annullata in modo esplicito.

SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Task>)

Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncBatchObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncBatchObserver.

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncBatchObservable<T> obs, Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<T>>,System.Threading.Tasks.Task> onNextAsync, Func<System.Threading.Tasks.Task> onCompletedAsync);

static member SubscribeAsync : Orleans.Streams.IAsyncBatchObservable<'T> * Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<'T>>, 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 IAsyncBatchObservable(Of T), onNextAsync As Func(Of IList(Of SequentialItem(Of T)), Task), onCompletedAsync As Func(Of Task)) As Task(Of StreamSubscriptionHandle(Of T))

Parametri di tipo

T

Tipo di oggetto prodotto dall'osservabile.

Parametri

obs

IAsyncBatchObservable<T>

Oggetto Observable.

onNextAsync

Func<IList<SequentialItem<T>>,Task>

Delegato chiamato per IAsyncBatchObserver.OnNextAsync.

onCompletedAsync

Func<Task>

Delegato chiamato per IAsyncBatchObserver.OnCompletedAsync.

Restituisce

Task<StreamSubscriptionHandle<T>>

Promessa per un oggetto StreamSubscriptionHandle che rappresenta la sottoscrizione. Il consumer può annullare la sottoscrizione usando questo handle. La sottoscrizione rimane attiva finché non viene annullata in modo esplicito.

SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, Func<Task>)

Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncBatchObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncBatchObserver.

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

static member SubscribeAsync : Orleans.Streams.IAsyncBatchObservable<'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> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>

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

Parametri di tipo

T

Tipo di oggetto prodotto dall'osservabile.

Parametri

obs

IAsyncBatchObservable<T>

Oggetto Observable.

onNextAsync

Func<IList<SequentialItem<T>>,Task>

Delegato chiamato per IAsyncBatchObserver.OnNextAsync.

onErrorAsync

Func<Exception,Task>

Delegato chiamato per IAsyncBatchObserver.OnErrorAsync.

onCompletedAsync

Func<Task>

Delegato chiamato per IAsyncBatchObserver.OnCompletedAsync.

Restituisce

Task<StreamSubscriptionHandle<T>>

Promessa per un oggetto StreamSubscriptionHandle che rappresenta la sottoscrizione. Il consumer può annullare la sottoscrizione usando questo handle. La sottoscrizione rimane attiva finché non viene annullata in modo esplicito.