AsyncObservableExtensions.SubscribeAsync Metodo
Definizione
Importante
Alcune informazioni sono relative alla release non definitiva del prodotto, che potrebbe subire modifiche significative prima della release definitiva. Microsoft non riconosce alcuna garanzia, espressa o implicita, in merito alle informazioni qui fornite.
Overload
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>) |
Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncObserver. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken) |
Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncObserver. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>) |
Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncObserver. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>) |
Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncObserver. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken) |
Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncObserver. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>) |
Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncObserver. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken) |
Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncObserver. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken, StreamFilterPredicate, Object) |
Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncObserver. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken) |
Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncObserver. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken, StreamFilterPredicate, Object) |
Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncObserver. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object) |
Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncObserver. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken, Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object) |
Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncObserver. |
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>)
- Origine:
- AsyncObservableExtensions.cs
Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di 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))Parametri di tipo
- T
Tipo di oggetto prodotto dall'osservabile.
Parametri
Oggetto Observable.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegato chiamato per IAsyncObserver.OnNextAsync.
Restituisce
Promessa per un oggetto StreamSubscriptionHandle che rappresenta la sottoscrizione. Il consumer può annullare la sottoscrizione usando questo handle. La sottoscrizione rimane attiva fino a quando non è annullata in modo esplicito.
Si applica a
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)
Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di 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);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))Parametri di tipo
- T
Tipo di oggetto prodotto dall'osservabile.
Parametri
Oggetto Observable.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegato chiamato per IAsyncObserver.OnNextAsync.
- token
- StreamSequenceToken
Sequenza di flusso da utilizzare come offset per avviare la sottoscrizione da.
Restituisce
Promessa per un oggetto StreamSubscriptionHandle che rappresenta la sottoscrizione. Il consumer può annullare la sottoscrizione usando questo handle. La sottoscrizione rimane attiva fino a quando non è annullata in modo esplicito.
Eccezioni
Generato se la funzione di filtro di flusso fornita non è adatta. In genere questo è perché non è un metodo statico.
Si applica a
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>)
- Origine:
- AsyncObservableExtensions.cs
Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di 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);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))Parametri di tipo
- T
Tipo di oggetto prodotto dall'osservabile.
Parametri
Oggetto Observable.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegato chiamato per IAsyncObserver.OnNextAsync.
Restituisce
Promessa per un oggetto StreamSubscriptionHandle che rappresenta la sottoscrizione. Il consumer può annullare la sottoscrizione usando questo handle. La sottoscrizione rimane attiva fino a quando non è annullata in modo esplicito.
Si applica a
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>)
- Origine:
- AsyncObservableExtensions.cs
Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di 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);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))Parametri di tipo
- T
Tipo di oggetto prodotto dall'osservabile.
Parametri
Oggetto Observable.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegato chiamato per IAsyncObserver.OnNextAsync.
Restituisce
Promessa per un oggetto StreamSubscriptionHandle che rappresenta la sottoscrizione. Il consumer può annullare la sottoscrizione usando questo handle. La sottoscrizione rimane attiva fino a quando non è annullata in modo esplicito.
Si applica a
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken)
Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di 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);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))Parametri di tipo
- T
Tipo di oggetto prodotto dall'osservabile.
Parametri
Oggetto Observable.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegato chiamato per IAsyncObserver.OnNextAsync.
- token
- StreamSequenceToken
Sequenza di flusso da utilizzare come offset per avviare la sottoscrizione da.
Restituisce
Promessa per un oggetto StreamSubscriptionHandle che rappresenta la sottoscrizione. Il consumer può annullare la sottoscrizione usando questo handle. La sottoscrizione rimane attiva fino a quando non è annullata in modo esplicito.
Eccezioni
Generato se la funzione di filtro di flusso fornita non è adatta. In genere questo è perché non è un metodo statico.
Si applica a
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>)
- Origine:
- AsyncObservableExtensions.cs
Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di 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))Parametri di tipo
- T
Tipo di oggetto prodotto dall'osservabile.
Parametri
Oggetto Observable.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegato chiamato per IAsyncObserver.OnNextAsync.
Restituisce
Promessa per un oggetto StreamSubscriptionHandle che rappresenta la sottoscrizione. Il consumer può annullare la sottoscrizione usando questo handle. La sottoscrizione rimane attiva fino a quando non è annullata in modo esplicito.
Si applica a
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken)
Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di 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))Parametri di tipo
- T
Tipo di oggetto prodotto dall'osservabile.
Parametri
Oggetto Observable.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegato chiamato per IAsyncObserver.OnNextAsync.
- token
- StreamSequenceToken
Sequenza di flusso da utilizzare come offset per avviare la sottoscrizione da.
Restituisce
Promessa per un oggetto StreamSubscriptionHandle che rappresenta la sottoscrizione. Il consumer può annullare la sottoscrizione usando questo handle. La sottoscrizione rimane attiva fino a quando non è annullata in modo esplicito.
Eccezioni
Generato se la funzione di filtro di flusso fornita non è adatta. In genere questo è perché non è un metodo statico.
Si applica a
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken, StreamFilterPredicate, Object)
- Origine:
- AsyncObservableExtensions.cs
Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di 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))Parametri di tipo
- T
Tipo di oggetto prodotto dall'osservabile.
Parametri
Oggetto Observable.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegte chiamato per IAsyncObserver.OnNextAsync.
- token
- StreamSequenceToken
Sequenza di flusso da utilizzare come offset per avviare la sottoscrizione da.
- filterFunc
- StreamFilterPredicate
Filtro da applicare per questa sottoscrizione
- filterData
- Object
Oggetto dati che verrà passato al filtroFunc. Questo in genere conterrà qualsiasi paramater richiesto dal filtroFunc per prendere la decisione di filtro.
Restituisce
Promessa per un oggetto StreamSubscriptionHandle che rappresenta la sottoscrizione. Il consumer può annullare la sottoscrizione usando questo handle. La sottoscrizione rimane attiva fino a quando non è esplicitamente annullata.
Eccezioni
Generato se la funzione di filtro di flusso fornita non è adatta. In genere questo è perché non è un metodo statico.
Si applica a
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)
Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di 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))Parametri di tipo
- T
Tipo di oggetto prodotto dall'osservabile.
Parametri
Oggetto Observable.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegato chiamato per IAsyncObserver.OnNextAsync.
- token
- StreamSequenceToken
Sequenza di flusso da utilizzare come offset per avviare la sottoscrizione da.
Restituisce
Promessa per un oggetto StreamSubscriptionHandle che rappresenta la sottoscrizione. Il consumer può annullare la sottoscrizione usando questo handle. La sottoscrizione rimane attiva fino a quando non è annullata in modo esplicito.
Eccezioni
Generato se la funzione di filtro di flusso fornita non è adatta. In genere questo è perché non è un metodo statico.
Si applica a
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken, StreamFilterPredicate, Object)
- Origine:
- AsyncObservableExtensions.cs
Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di 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))Parametri di tipo
- T
Tipo di oggetto prodotto dall'osservabile.
Parametri
Oggetto Observable.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegte chiamato per IAsyncObserver.OnNextAsync.
- token
- StreamSequenceToken
Sequenza di flusso da utilizzare come offset per avviare la sottoscrizione da.
- filterFunc
- StreamFilterPredicate
Filtro da applicare per questa sottoscrizione
- filterData
- Object
Oggetto dati che verrà passato al filtroFunc. Questo in genere conterrà qualsiasi paramater richiesto dal filtroFunc per prendere la decisione di filtro.
Restituisce
Promessa per un oggetto StreamSubscriptionHandle che rappresenta la sottoscrizione. Il consumer può annullare la sottoscrizione usando questo handle. La sottoscrizione rimane attiva fino a quando non è esplicitamente annullata.
Eccezioni
Generato se la funzione di filtro di flusso fornita non è adatta. In genere questo è perché non è un metodo statico.
Si applica a
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object)
- Origine:
- AsyncObservableExtensions.cs
Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di 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))Parametri di tipo
- T
Tipo di oggetto prodotto dall'osservabile.
Parametri
Oggetto Observable.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegte chiamato per IAsyncObserver.OnNextAsync.
- token
- StreamSequenceToken
Sequenza di flusso da utilizzare come offset per avviare la sottoscrizione da.
- filterFunc
- StreamFilterPredicate
Filtro da applicare per questa sottoscrizione
- filterData
- Object
Oggetto dati che verrà passato al filtroFunc. Questo in genere conterrà qualsiasi paramater richiesto dal filtroFunc per prendere la decisione di filtro.
Restituisce
Promessa per un oggetto StreamSubscriptionHandle che rappresenta la sottoscrizione. Il consumer può annullare la sottoscrizione usando questo handle. La sottoscrizione rimane attiva fino a quando non è esplicitamente annullata.
Eccezioni
Generato se la funzione di filtro di flusso fornita non è adatta. In genere questo è perché non è un metodo statico.
Si applica a
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken, Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object)
- Origine:
- AsyncObservableExtensions.cs
Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di 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))Parametri di tipo
- T
Tipo di oggetto prodotto dall'osservabile.
Parametri
Oggetto Observable.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegte chiamato per IAsyncObserver.OnNextAsync.
- token
- StreamSequenceToken
Sequenza di flusso da utilizzare come offset per avviare la sottoscrizione da.
- filterFunc
- StreamFilterPredicate
Filtro da applicare per questa sottoscrizione
- filterData
- Object
Oggetto dati che verrà passato al filtroFunc. Questo in genere conterrà qualsiasi paramater richiesto dal filtroFunc per prendere la decisione di filtro.
Restituisce
Promessa per un oggetto StreamSubscriptionHandle che rappresenta la sottoscrizione. Il consumer può annullare la sottoscrizione usando questo handle. La sottoscrizione rimane attiva fino a quando non è esplicitamente annullata.
Eccezioni
Generato se la funzione di filtro di flusso fornita non è adatta. In genere questo è perché non è un metodo statico.