Compartir a través de

Clase T> AsyncSubject<

Representa el resultado de una operación asincrónica.

Jerarquía de herencia

System.Object
  System.Reactive.Subjects.AsyncSubject<T>

Espacio de nombres:System.Reactive.Subjects
Ensamblaje: System.Reactive (en System.Reactive.dll)

Sintaxis

'Declaration
Public NotInheritable Class AsyncSubject(Of T) _
    Implements ISubject(Of T), ISubject(Of T, T),  _
    IObserver(Of T), IObservable(Of T), IDisposable

'Usage
Dim instance As AsyncSubject(Of T)

public sealed class AsyncSubject<T> : ISubject<T>, 
    ISubject<T, T>, IObserver<T>, IObservable<T>, IDisposable

generic<typename T>
public ref class AsyncSubject sealed : ISubject<T>, 
    ISubject<T, T>, IObserver<T>, IObservable<T>, IDisposable

[<SealedAttribute>]
type AsyncSubject<'T> =  
    class
        interface ISubject<'T>
        interface ISubject<'T, 'T>
        interface IObserver<'T>
        interface IObservable<'T>
        interface IDisposable
    end

JScript does not support generic types and methods.

Parámetros de tipo

  • T
    Tipo.

El tipo AsyncSubject<T> expone los siguientes miembros.

Constructores

  Nombre Descripción
Public AsyncSubject<T> Inicializa una nueva instancia de la clase AsyncSubject<T> .

Superior

Métodos

  Nombre Descripción
Public Dispose Cancelar la suscripción a todos los observadores y liberar recursos.
Public Es igual a (Se hereda de Object).
protegido Método protegido Finalización (Se hereda de Object).
Public GetHashCode (Se hereda de Object).
Public GetType (Se hereda de Object).
protegido Método protegido MemberwiseClone (Se hereda de Object).
Public OnCompleted Notifica a todos los observadores suscritos del final de la secuencia, lo que también hace que se envíe el último valor recibido (si existe).
Public OnError Notifica a todos los observadores suscritos con la excepción.
Public OnNext Envía un valor al asunto. El último valor recibido antes de la finalización correcta se enviará a todos los observadores suscritos.
Public Suscribirse Suscribe un observador al sujeto.
Public ToString (Se hereda de Object).

Superior

Métodos de extensión

  Nombre Descripción
pública Método de extensión pública >T(Func<T, T, T>) agregado< Sobrecargado. Aplica una función de acumulador a través de una secuencia observable. (Definido por Observable).
pública Método de extensión pública Aggregate<T, TAccumulate>(TAccumulate, Func<TAccumulate, T, TAccumulate>) Sobrecargado. Aplica una función de acumulador sobre una secuencia observable con el valor de inicialización especificado. (Definido por Observable).
pública Método de extensión pública Todas las<T> Determina si todos los elementos de una secuencia observable cumplen una condición. (Definido por Observable).
pública Método de extensión pública Amb<T> Propaga la secuencia observable que reacciona primero con la primera y la segunda secuencia especificadas. (Definido por Observable).
pública Método de extensión pública Y<T, TRight> Coincide cuando ambas secuencias observables tienen un valor disponible. (Definido por Observable).
pública Método de extensión pública Cualquier<T>() Sobrecargado. Determina si una secuencia observable contiene elementos. (Definido por Observable).
pública Método de extensión pública Any<T>(Func<T, Boolean>) Sobrecargado. Determina si todos los elementos de una secuencia observable cumplen una condición. (Definido por Observable).
pública Método de extensión pública AsObservable<T> Oculta la identidad de una secuencia observable. (Definido por Observable).
pública Método de extensión pública AsObserver<T> Oculta la identidad de un observador. (Definido por Observer).
pública Método de extensión pública AsQbservable<T> Convierte una secuencia observable en una secuencia observable consultable. (Definido por Qbservable).
pública Método de extensión pública AssertEqual<T> (Definido por Extensions).
pública Método de extensión pública T<>(Int32) Sobrecargado. Indica cada elemento de una secuencia observable en búferes no superpuestos consecutivos que se generan en función de la información de recuento de elementos. (Definido por Observable).
pública Método de extensión pública T>(TimeSpan) del búfer< Sobrecargado. Indica cada elemento de una secuencia observable en búferes no superpuestos consecutivos que se generan en función de la información de tiempo. (Definido por Observable).
pública Método de extensión pública Buffer<T>(Int32, Int32) Sobrecargado. Indica cada elemento de una secuencia observable en cero o más búferes que se generan en función de la información de recuento de elementos. (Definido por Observable).
pública Método de extensión pública T<>(TimeSpan, IScheduler) Sobrecargado. Indica cada elemento de una secuencia observable en búferes no superpuestos consecutivos que se generan en función de la información de tiempo. (Definido por Observable).
pública Método de extensión pública T>(TimeSpan<, TimeSpan) Sobrecargado. Indica cada elemento de una secuencia observable en cero o más búferes que se generan en función de la información de tiempo. (Definido por Observable).
pública Método de extensión pública T<>(TimeSpan, Int32) Sobrecargado. Indica cada elemento de una secuencia observable en un búfer que se envía cuando está lleno o una cantidad determinada de tiempo transcurrido. (Definido por Observable).
pública Método de extensión pública Buffer<T>(TimeSpan, TimeSpan, IScheduler) Sobrecargado. Indica cada elemento de una secuencia observable en cero o más búferes que se generan en función de la información de tiempo. (Definido por Observable).
pública Método de extensión pública Buffer<T>(TimeSpan, Int32, IScheduler) Sobrecargado. Indica cada elemento de una secuencia observable en un búfer que se envía cuando está lleno o una cantidad determinada de tiempo transcurrido. (Definido por Observable).
pública Método de extensión pública Buffer<T, TBufferClosing>(Func<IObservable<TBufferClosing>>) Sobrecargado. Indica cada elemento de una secuencia observable en búferes no superpuestos consecutivos. (Definido por Observable).
pública Método de extensión pública Buffer<T, TBufferOpening, TBufferClosing>(IObservable<TBufferOpening>, Func<TBufferOpening, IObservable<TBufferClosing>>) Sobrecargado. Indica cada elemento de una secuencia observable consultable en búferes no superpuestos consecutivos. (Definido por Observable).
pública Método de extensión pública Catch<T>(IObservable<T>) Sobrecargado. Continúa una secuencia observable terminada por una excepción con la siguiente secuencia observable. (Definido por Observable).
pública Método de extensión pública Catch<T, TException>(Func<TException, IObservable<T>>) Sobrecargado. Continúa una secuencia observable terminada por una excepción del tipo especificado con la secuencia observable generada por el controlador. (Definido por Observable).
pública Método de extensión pública CombineLatest<T, TSecond, TResult> Combina dos secuencias observables en una secuencia observable mediante el uso de la función selector cada vez que una de las secuencias observables genera un elemento. (Definido por Observable).
pública Método de extensión pública Concat<T> Concatena dos secuencias observables. (Definido por Observable).
pública Método de extensión pública Contiene<T>(T) Sobrecargado. Determina si una secuencia observable contiene un elemento especificado mediante el comparador de igualdad predeterminado. (Definido por Observable).
pública Método de extensión pública Contiene<T>(T, IEqualityComparer<T>) Sobrecargado. Determina si una secuencia observable contiene un elemento especificado mediante un objeto System.Collections.Generic.IEqualityComparer&lt especificado; T&gt;. (Definido por Observable).
pública Método de extensión pública Recuento<de T> Devuelve un Int32 que representa el número total de elementos de una secuencia observable. (Definido por Observable).
pública Método de extensión pública DefaultIfEmpty<T>() Sobrecargado. Devuelve los elementos de la secuencia especificada o el valor predeterminado del parámetro de tipo en una secuencia singleton si la secuencia está vacía. (Definido por Observable).
pública Método de extensión pública DefaultIfEmpty<T>(T) Sobrecargado. Devuelve los elementos de la secuencia especificada o el valor predeterminado del parámetro de tipo en una secuencia singleton si la secuencia está vacía. (Definido por Observable).
pública Método de extensión pública Retraso<T>(TimeSpan) Sobrecargado. Indica la secuencia observable en tiempo de vencimiento con el origen y dueTime especificados. (Definido por Observable).
pública Método de extensión pública Delay<T>(DateTimeOffset) Sobrecargado. Indica la secuencia observable en tiempo de vencimiento con el origen y dueTime especificados. (Definido por Observable).
pública Método de extensión pública Delay<T>(TimeSpan, IScheduler) Sobrecargado. Indica la secuencia observable por tiempo de vencimiento con el origen, dueTime y scheduler especificados. (Definido por Observable).
pública Método de extensión pública Delay<T>(DateTimeOffset, IScheduler) Sobrecargado. Indica la secuencia observable por tiempo de vencimiento con el origen, dueTime y scheduler especificados. (Definido por Observable).
pública Método de extensión pública >T() distinto< Sobrecargado. Devuelve una secuencia observable que contiene solo elementos distintos con un origen especificado. (Definido por Observable).
pública Método de extensión pública >T(<IEqualityComparer<T>) Sobrecargado. Devuelve una secuencia observable que solo contiene elementos distintos según el comparador. (Definido por Observable).
pública Método de extensión pública Distinct<T, TKey>(Func<T, TKey>) Sobrecargado. Devuelve una secuencia observable que solo contiene elementos distintos según keySelector. (Definido por Observable).
pública Método de extensión pública Distinct<T, TKey>(Func<T, TKey>, IEqualityComparer<TKey>) Sobrecargado. Devuelve una secuencia observable que solo contiene elementos distintos según keySelector. (Definido por Observable).
pública Método de extensión pública DistinctUntilChanged<T>() Sobrecargado. Devuelve una secuencia observable que contiene solo distintos elementos contiguos con un origen especificado. (Definido por Observable).
pública Método de extensión pública DistinctUntilChanged<T>(IEqualityComparer<T>) Sobrecargado. Devuelve una secuencia observable que contiene solo distintos elementos contiguos según el comparador. (Definido por Observable).
pública Método de extensión pública DistinctUntilChanged<T, TKey>(Func<T, TKey>) Sobrecargado. Devuelve una secuencia observable que contiene solo distintos elementos contiguos según keySelector. (Definido por Observable).
pública Método de extensión pública DistinctUntilChanged<T, TKey>(Func<T, TKey>, IEqualityComparer<TKey>) Sobrecargado. Devuelve una secuencia observable que contiene solo distintos elementos contiguos según keySelector y el comparador. (Definido por Observable).
pública Método de extensión pública Hacer<T>(Acción<T>) Sobrecargado. Invoca una acción para cada elemento de la secuencia observable. (Definido por Observable).
pública Método de extensión pública Do<T>(IObserver<T>) Sobrecargado. Invoca una acción para cada elemento de la secuencia observable e invoca una acción tras la finalización excepcional de la secuencia observable. (Definido por Observable).
pública Método de extensión pública Hacer<T>(Acción<T>, Acción) Sobrecargado. Invoca una acción para cada elemento de la secuencia observable e invoca una acción tras la finalización correcta de la secuencia observable. (Definido por Observable).
pública Método de extensión pública Do<T>(Action<T>, Action<Exception>) Sobrecargado. Invoca una acción para cada elemento de la secuencia observable e invoca una acción tras la finalización excepcional de la secuencia observable. (Definido por Observable).
pública Método de extensión pública Do<T>(Action<T>, Action<Exception>, Action) Sobrecargado. Invoca una acción para cada elemento de la secuencia observable e invoca una acción tras la finalización correcta o excepcional de la secuencia observable. (Definido por Observable).
pública Método de extensión pública ElementAt<T> Devuelve el elemento situado en un índice especificado de una secuencia. (Definido por Observable).
pública Método de extensión pública ElementAtOrDefault<T> Devuelve el elemento situado en un índice especificado de una secuencia o un valor predeterminado si el índice está fuera del intervalo. (Definido por Observable).
pública Método de extensión pública Por último<, T> Invoca una acción especificada después de que la secuencia observable de origen finalice normalmente o mediante una excepción. (Definido por Observable).
pública Método de extensión pública Primera<T>() Sobrecargado. Devuelve el primer elemento de una secuencia observable con un origen especificado. (Definido por Observable).
pública Método de extensión pública First<T(Func<T>, Boolean>) Sobrecargado. Devuelve el primer elemento de una secuencia observable que coincide con el predicado. (Definido por Observable).
pública Método de extensión pública FirstOrDefault<T>() Sobrecargado. Devuelve el primer elemento de una secuencia observable o un valor predeterminado si no se encuentra ningún valor. (Definido por Observable).
pública Método de extensión pública FirstOrDefault<T>(Func<T, Boolean>) Sobrecargado. Devuelve el primer elemento de una secuencia observable que coincide con el predicado o un valor predeterminado si no se encuentra ningún valor. (Definido por Observable).
pública Método de extensión pública Foo<T, R> (Definido por MyExt).
pública Método de extensión pública ForEach<T> Invoca una acción para cada elemento de la secuencia observable y se bloquea hasta que finaliza la secuencia. (Definido por Observable).
pública Método de extensión pública GetEnumerator<T> Devuelve un enumerador que enumera todos los valores de la secuencia observable. (Definido por Observable).
pública Método de extensión pública GroupBy<T, TKey>(Func<T, TKey>) Sobrecargado. Agrupa los elementos de una secuencia observable según una función de selector de claves especificada. (Definido por Observable).
pública Método de extensión pública GroupBy<T, TKey>(Func<T, TKey>, IEqualityComparer<TKey>) Sobrecargado. Agrupa los elementos de una secuencia observable según una función y comparador de selector de claves especificados. (Definido por Observable).
pública Método de extensión pública GroupBy<T, TKey, TElement>(Func<T, TKey>, Func<T, TElement>) Sobrecargado. Agrupa los elementos de una secuencia observable y selecciona los elementos resultantes mediante una función especificada. (Definido por Observable).
pública Método de extensión pública GroupBy<T, TKey, TElement>(Func<T, TKey, Func<T, TElement>, IEqualityComparer<TKey>>) Sobrecargado. Agrupa los elementos de una secuencia observable según una función y comparador de selector de claves especificados y selecciona los elementos resultantes mediante una función especificada. (Definido por Observable).
pública Método de extensión pública GroupByUntil<T, TKey, TDuration>(Func<T, TKey, Func<IGroupedObservable TKey>, T>, IObservable<<TDuration>>) Sobrecargado. Agrupa los elementos de una secuencia observable según una función de selector de claves especificada. (Definido por Observable).
pública Método de extensión pública GroupByUntil<T, TKey, TDuration>(Func<T, TKey, Func<IGroupedObservable TKey>, T>, IObservable<<TDuration>>, IEqualityComparer<TKey>) Sobrecargado. Agrupa los elementos de una secuencia observable según una función y comparador de selector de claves especificados. (Definido por Observable).
pública Método de extensión pública GroupByUntil<T, TKey, TElement, TDuration>(Func<T, TKey>, Func<T, TElement>, Func<IGroupedObservable TKey, TElement>, IObservable<<TDuration>>) Sobrecargado. Agrupa los elementos de una secuencia observable según una función de selector de claves especificada y selecciona los elementos resultantes mediante una función especificada. (Definido por Observable).
pública Método de extensión pública GroupByUntil<T, TKey, TElement, TDuration>(Func<T, TKey>, Func<T, TElement>, Func<IGroupedObservable<TKey, TElement>, IObservable<TDuration>>, IEqualityComparer<TKey>) Sobrecargado. Agrupa los elementos de una secuencia observable según una función y comparador de selector de claves especificados y selecciona los elementos resultantes mediante una función especificada. (Definido por Observable).
pública Método de extensión pública GroupJoin<T, TRight, TLeftDuration, TRightDuration, TResult> Correlaciona los elementos de dos secuencias en función de duraciones superpuestas y agrupa los resultados. (Definido por Observable).
pública Método de extensión pública IgnoreElements<T> Omite todos los valores de una secuencia observable dejando solo los mensajes de finalización. (Definido por Observable).
pública Método de extensión pública Join<T, TRight, TLeftDuration, TRightDuration, TResult> Correlaciona los elementos de dos secuencias en función de duraciones superpuestas. (Definido por Observable).
pública Método de extensión pública Última<T>() Sobrecargado. Devuelve el último elemento de una secuencia observable con un origen especificado. (Definido por Observable).
pública Método de extensión pública Last<T(Func<T>, Boolean>) Sobrecargado. Devuelve el último elemento de una secuencia observable que coincide con el predicado. (Definido por Observable).
pública Método de extensión pública LastOrDefault<T>() Sobrecargado. Devuelve el último elemento de la secuencia observable o un valor predeterminado si no se encuentra ningún valor. (Definido por Observable).
pública Método de extensión pública LastOrDefault<T>(Func<T, Boolean>) Sobrecargado. Devuelve el último elemento de una secuencia observable que coincide con el predicado o un valor predeterminado si no se encuentra ningún valor. (Definido por Observable).
pública Método de extensión pública T más reciente<> Muestra el valor más reciente en una secuencia observable. (Definido por Observable).
pública Método de extensión pública LongCount<T> Devuelve un Int64 que representa el número total de elementos de una secuencia observable. (Definido por Observable).
pública Método de extensión pública Materializar<T> Materializa las notificaciones implícitas de una secuencia observable como valores de notificación explícitos. (Definido por Observable).
pública Método de extensión pública Máximo<de T>() Sobrecargado. Devuelve el elemento máximo de una secuencia observable. (Definido por Observable).
pública Método de extensión pública Max<T>(IComparer<T>) Sobrecargado. Devuelve el valor máximo de una secuencia observable según el comparador especificado. (Definido por Observable).
pública Método de extensión pública MaxBy<T, TKey>(Func<T, TKey>) Sobrecargado. Devuelve los elementos de una secuencia observable con el valor de clave máximo. (Definido por Observable).
pública Método de extensión pública MaxBy<T, TKey>(Func<T, TKey, IComparer<TKey>>) Sobrecargado. Devuelve los elementos de una secuencia observable con el valor de clave máximo. (Definido por Observable).
pública Método de extensión pública Combinar<T>(IObservable<T>) Sobrecargado. Combina una secuencia observable de secuencias observables en una secuencia observable. (Definido por Observable).
pública Método de extensión pública Merge<T>(IObservable<T>, IScheduler) Sobrecargado. Combina dos secuencias observables en una sola secuencia observable. (Definido por Observable).
pública Método de extensión pública Min<T>() Sobrecargado. Devuelve el elemento mínimo de una secuencia observable. (Definido por Observable).
pública Método de extensión pública Min<T>(IComparer<T>) Sobrecargado. Devuelve el valor mínimo de una secuencia observable según el comparador especificado. (Definido por Observable).
pública Método de extensión pública MinBy<T, TKey>(Func<T, TKey>) Sobrecargado. Devuelve los elementos de una secuencia observable con el valor de clave mínimo. (Definido por Observable).
pública Método de extensión pública MinBy<T, TKey>(Func<T, TKey, IComparer<TKey>>) Sobrecargado. Devuelve los elementos de una secuencia observable con el valor de clave mínimo según el comparador especificado. (Definido por Observable).
pública Método de extensión pública MostRecent<T> Muestra el valor más reciente en una secuencia observable. (Definido por Observable).
pública Método de extensión pública Multidifusión<T, TResult>(ISubject<T, TResult>) Sobrecargado. Devuelve una secuencia observable conectable que tras la conexión hace que la secuencia de origen inserte los resultados en el asunto especificado. (Definido por Observable).
pública Método de extensión pública Multidifusión<T, TIntermediate, TResult>(Func<ISubject<T, TIntermediate>>, Func<IObservable<TIntermediate>, IObservable<TResult>>) Sobrecargado. Devuelve una secuencia observable que contiene los elementos de una secuencia generada por la multidifusión de la secuencia de origen dentro de una función selectora. (Definido por Observable).
pública Método de extensión pública Siguiente<T> Muestra el siguiente valor (bloqueo sin almacenamiento en búfer) de en una secuencia observable. (Definido por Observable).
pública Método de extensión pública ObserveOn<T>(SynchronizationContext) Sobrecargado. Notificar de forma asincrónica a los observadores en el contexto de sincronización especificado. (Definido por Observable).
pública Método de extensión pública ObserveOn<T>(Control) Sobrecargado. (Definido por ControlObservable).
pública Método de extensión pública ObserveOn<T>(Dispatcher) Sobrecargado. (Definido por DispatcherObservable).
pública Método de extensión pública ObserveOn<T>(DispatcherScheduler) Sobrecargado. (Definido por DispatcherObservable).
pública Método de extensión pública ObserveOn<T>(IScheduler) Sobrecargado. Notificar de forma asincrónica a los observadores en el programador especificado. (Definido por Observable).
pública Método de extensión pública ObserveOnDispatcher<T> (Definido por DispatcherObservable).
pública Método de extensión pública OnErrorResumeNext<T> Continúa una secuencia observable que finaliza normalmente o mediante una excepción con la siguiente secuencia observable. (Definido por Observable).
pública Método de extensión pública Publicar<T>() Sobrecargado. Devuelve una secuencia observable conectable que comparte una sola suscripción a la secuencia subyacente. (Definido por Observable).
pública Método de extensión pública Publicar<T>(T) Sobrecargado. Devuelve una secuencia observable conectable que comparte una sola suscripción a la secuencia subyacente y comienza por initialValue. (Definido por Observable).
pública Método de extensión pública Publicar<T, TResult>(Func<IObservable<T>, IObservable<TResult>>) Sobrecargado. Devuelve una secuencia observable que es el resultado de invocar el selector en una secuencia observable conectable que comparte una sola suscripción a la secuencia subyacente. (Definido por Observable).
pública Método de extensión pública Publicar<T, TResult>(Func<IObservable<T>, IObservable<TResult>>, T) Sobrecargado. Devuelve una secuencia observable conectable que comparte una sola suscripción a la secuencia subyacente y comienza por initialValue. (Definido por Observable).
pública Método de extensión pública PublishLast<T>() Sobrecargado. Devuelve una secuencia observable conectable que comparte una sola suscripción a la secuencia subyacente que contiene solo la última notificación. (Definido por Observable).
pública Método de extensión pública PublishLast<T, TResult>(Func<IObservable<T>, IObservable<TResult>>) Sobrecargado. Devuelve una secuencia observable que es el resultado de invocar el selector en una secuencia observable conectable que comparte una sola suscripción a la secuencia subyacente que contiene solo la última notificación. (Definido por Observable).
pública Método de extensión pública Repetir<T>() Sobrecargado. Repite la secuencia observable indefinidamente. (Definido por Observable).
pública Método de extensión pública Repetir<T>(Int32) Sobrecargado. Repite la secuencia observable indefinidamente. (Definido por Observable).
pública Método de extensión pública Reproducción<de T>() Sobrecargado. Devuelve una secuencia observable conectable que comparte una sola suscripción a la secuencia subyacente que reproduce todas las notificaciones. (Definido por Observable).
pública Método de extensión pública Reproducción<de T>(TimeSpan) Sobrecargado. Devuelve una secuencia observable conectable que comparte una sola suscripción a la secuencia subyacente que reproduce todas las notificaciones dentro de la ventana. (Definido por Observable).
pública Método de extensión pública Replay<T>(Int32) Sobrecargado. Devuelve una secuencia observable conectable que comparte una sola suscripción a las notificaciones bufferSize de reproducción de secuencia subyacente. (Definido por Observable).
pública Método de extensión pública Replay<T>(IScheduler) Sobrecargado. Devuelve una secuencia observable conectable que comparte una sola suscripción a la secuencia subyacente que reproduce todas las notificaciones. (Definido por Observable).
pública Método de extensión pública Replay<T>(TimeSpan, IScheduler) Sobrecargado. Devuelve una secuencia observable conectable que comparte una sola suscripción a la secuencia subyacente que reproduce todas las notificaciones dentro de la ventana. (Definido por Observable).
pública Método de extensión pública Replay<T>(Int32, IScheduler) Sobrecargado. Devuelve una secuencia observable conectable que comparte una sola suscripción a las notificaciones bufferSize de reproducción de secuencia subyacente. (Definido por Observable).
pública Método de extensión pública Replay<T>(Int32, TimeSpan) Sobrecargado. Devuelve una secuencia observable conectable que comparte una sola suscripción al búfer de reproducción de secuencias subyacenteSize notifications within window . (Definido por Observable).
pública Método de extensión pública Replay<T>(Int32, TimeSpan, IScheduler) Sobrecargado. Devuelve una secuencia observable conectable que comparte una sola suscripción al búfer de reproducción de secuencias subyacenteSize notifications within window . (Definido por Observable).
pública Método de extensión pública Replay<T, TResult>(Func<IObservable<T>, IObservable<TResult>>) Sobrecargado. Devuelve una secuencia observable que es el resultado de invocar el selector en una secuencia observable conectable que comparte una sola suscripción a la secuencia subyacente y comienza por el valor inicial. (Definido por Observable).
pública Método de extensión pública Replay<T, TResult>(Func<IObservable<T>, IObservable<TResult>>, IScheduler) Sobrecargado. Devuelve una secuencia observable que es el resultado de invocar el selector en una secuencia observable conectable que comparte una sola suscripción a la secuencia subyacente reproduciendo todas las notificaciones. (Definido por Observable).
pública Método de extensión pública Replay<T, TResult>(Func<IObservable<T>, IObservable<TResult>>, TimeSpan) Sobrecargado. Devuelve una secuencia observable que es el resultado de invocar el selector en una secuencia observable conectable que comparte una sola suscripción a la secuencia subyacente reproduciendo todas las notificaciones dentro de la ventana. (Definido por Observable).
pública Método de extensión pública Replay<T, TResult>(Func<IObservable<T>, IObservable<TResult>>, Int32) Sobrecargado. Devuelve una secuencia observable que es el resultado de invocar el selector en una secuencia observable conectable que comparte una sola suscripción al búfer de reproducción de secuencias subyacenteSize notifications. (Definido por Observable).
pública Método de extensión pública Replay<T, TResult>(Func<IObservable<T>, IObservable<TResult>>, TimeSpan, IScheduler) Sobrecargado. Devuelve una secuencia observable que es el resultado de invocar el selector en una secuencia observable conectable que comparte una sola suscripción a la secuencia subyacente reproduciendo todas las notificaciones dentro de la ventana. (Definido por Observable).
pública Método de extensión pública Replay<T, TResult>(Func<IObservable<T>, IObservable<TResult>>, Int32, IScheduler) Sobrecargado. Devuelve una secuencia observable que es el resultado de invocar el selector en una secuencia observable conectable que comparte una sola suscripción al búfer de reproducción de secuencias subyacenteSize notifications. (Definido por Observable).
pública Método de extensión pública Replay<T, TResult>(Func<IObservable<T>, IObservable<TResult>>, Int32, TimeSpan) Sobrecargado. Devuelve una secuencia observable que es el resultado de invocar el selector en una secuencia observable conectable que comparte una sola suscripción al búfer de reproducción de secuencias subyacenteSize notifications within window. (Definido por Observable).
pública Método de extensión pública Replay<T, TResult>(Func<IObservable<T>, IObservable<TResult>>, Int32, TimeSpan, IScheduler) Sobrecargado. Devuelve una secuencia observable que es el resultado de invocar el selector en una secuencia observable conectable que comparte una sola suscripción al búfer de reproducción de secuencias subyacenteSize notifications within window. (Definido por Observable).
pública Método de extensión pública Reintentar<T>() Sobrecargado. Repite la secuencia observable de origen hasta que finaliza correctamente. (Definido por Observable).
pública Método de extensión pública Reintento<T>(Int32) Sobrecargado. Repite la secuencia observable de origen hasta que finaliza correctamente. (Definido por Observable).
pública Método de extensión pública T>(TimeSpan) de<ejemplo Sobrecargado. Muestra la secuencia observable en cada intervalo. (Definido por Observable).
pública Método de extensión pública Ejemplo<T>(TimeSpan, IScheduler) Sobrecargado. Muestra la secuencia observable en cada intervalo con el origen, el intervalo y el programador especificados. (Definido por Observable).
pública Método de extensión pública T<de ejemplo, TSample>(IObservable<TSample>) Sobrecargado. Muestra la secuencia observable en tics de muestreo con el origen y el muestreador especificados. (Definido por Observable).
pública Método de extensión pública Scan<T>(Func<T, T, T>) Sobrecargado. Aplica una función de acumulador sobre una secuencia observable y devuelve cada resultado intermedio con el origen y el acumulador especificados. (Definido por Observable).
pública Método de extensión pública Scan<T, TAccumulate(TAccumulate>, Func<TAccumulate, T, TAccumulate>) Sobrecargado. Aplica una función de acumulador sobre una secuencia observable y devuelve cada resultado intermedio con el origen, inicialización y acumulador especificados. (Definido por Observable).
pública Método de extensión pública Seleccione<T, TResult>(Func<T, TResult>) Sobrecargado. Proyecta cada elemento de una secuencia observable en un nuevo formulario con el origen y el selector especificados. (Definido por Observable).
pública Método de extensión pública Seleccione<T, TResult>(Func<T, Int32, TResult>) Sobrecargado. Proyecta cada elemento de una secuencia observable en un nuevo formulario incorporando el índice del elemento con el origen y el selector especificados. (Definido por Observable).
pública Método de extensión pública SelectMany<T, TOther>(IObservable<TOther>) Sobrecargado. Proyecta cada elemento de una secuencia observable en una secuencia observable y aplana las secuencias observables resultantes en una secuencia observable. (Definido por Observable).
pública Método de extensión pública SelectMany<T, TResult>(Func<T, IObservable<TResult>>) Sobrecargado. Proyecta cada elemento de una secuencia observable en una secuencia observable y aplana las secuencias observables resultantes en una secuencia observable. (Definido por Observable).
pública Método de extensión pública SelectMany<T, TResult>(Func<T, IEnumerable<TResult>>) Sobrecargado. Proyecta cada elemento de una secuencia observable en una secuencia observable y aplana las secuencias observables resultantes en una secuencia observable. (Definido por Observable).
pública Método de extensión pública SelectMany<T, TResult>(Func<T, IObservable<TResult>>, Func<Exception, IObservable<TResult>>, Func<IObservable<TResult>>) Sobrecargado. Proyecta cada elemento de una secuencia observable en una secuencia observable y aplana las secuencias observables resultantes en una secuencia observable. (Definido por Observable).
pública Método de extensión pública SelectMany<T, TCollection, TResult>(Func<T, IEnumerable<TCollection>>, Func<T, TCollection, TResult>) Sobrecargado. Proyecta cada elemento de una secuencia observable en una secuencia observable y aplana las secuencias observables resultantes en una secuencia observable. (Definido por Observable).
pública Método de extensión pública SelectMany<T, TCollection, TResult>(Func<T, IObservable<TCollection>>, Func<T, TCollection, TResult>) Sobrecargado. Proyecta cada elemento de una secuencia observable en una secuencia observable y acopla las secuencias observables resultantes en una secuencia observable. (Definido por Observable).
pública Método de extensión pública SequenceEqual<T>(IObservable<T>) Sobrecargado. Determina si dos secuencias son iguales comparando los elementos en pares. (Definido por Observable).
pública Método de extensión pública SequenceEqual<T>(IObservable<T>, IEqualityComparer<T>) Sobrecargado. Determina si dos secuencias son iguales comparando los elementos en pares mediante un comparador de igualdad especificado. (Definido por Observable).
pública Método de extensión pública >T() único< Sobrecargado. Devuelve el único elemento de una secuencia observable y produce una excepción si no hay exactamente un elemento en la secuencia observable. (Definido por Observable).
pública Método de extensión pública T<(Func<T, Boolean>)> Sobrecargado. Devuelve el único elemento de una secuencia observable que coincide con el predicado y produce una excepción si no hay exactamente un elemento en la secuencia observable. (Definido por Observable).
pública Método de extensión pública SingleOrDefault<T>() Sobrecargado. Devuelve el único elemento de una secuencia observable o un valor predeterminado si la secuencia observable está vacía. (Definido por Observable).
pública Método de extensión pública SingleOrDefault<T>(Func<T, Boolean>) Sobrecargado. Devuelve el único elemento de una secuencia observable que coincide con el predicado o un valor predeterminado si no se encuentra ningún valor. (Definido por Observable).
pública Método de extensión pública Omitir<T> Omite un número especificado de valores en una secuencia observable y, a continuación, devuelve los valores restantes. (Definido por Observable).
pública Método de extensión pública SkipLast<T> Omite un número especificado de elementos al final de una secuencia observable. (Definido por Observable).
pública Método de extensión pública SkipUntil<T, TOther> Devuelve los valores de la secuencia observable de origen solo después de que la otra secuencia observable genere un valor. (Definido por Observable).
pública Método de extensión pública SkipWhile<T>(Func<T, Boolean>) Sobrecargado. Omite los valores de una secuencia observable siempre que una condición especificada sea true y, a continuación, devuelve los valores restantes. (Definido por Observable).
pública Método de extensión pública SkipWhile<T>(Func<T, Int32, Boolean>) Sobrecargado. Omite los valores de una secuencia observable siempre que una condición especificada sea true y, a continuación, devuelve los valores restantes. (Definido por Observable).
pública Método de extensión pública StartWith<T>[]) Sobrecargado. Antepone una secuencia de valores a una secuencia observable con el origen y los valores especificados. (Definido por Observable).
pública Método de extensión pública StartWith<T>(IScheduler, T[]) Sobrecargado. Antepone una secuencia de valores a una secuencia observable con el origen, el programador y los valores especificados. (Definido por Observable).
pública Método de extensión pública Suscribirse<a T>() Sobrecargado. Evalúa la secuencia observable con un origen especificado. (Definido por ObservableExtensions).
pública Método de extensión pública Suscribir<T>(Acción<T>) Sobrecargado. Suscribe un controlador de elementos a una secuencia observable. (Definido por ObservableExtensions).
pública Método de extensión pública Subscribe<T>(Action<T>, Action<Exception>) Sobrecargado. Suscribe un controlador de elementos y un controlador de excepciones a una secuencia observable. (Definido por ObservableExtensions).
pública Método de extensión pública Subscribe<T>(Action<T>, Action) Sobrecargado. Suscribe un controlador de elementos y un controlador de finalización a una secuencia observable. (Definido por ObservableExtensions).
pública Método de extensión pública Subscribe<T>(Action<T>, Action<Exception>, Action) Sobrecargado. Suscribe un controlador de elementos, un controlador de excepciones y un controlador de finalización a una secuencia observable. (Definido por ObservableExtensions).
pública Método de extensión pública SubscribeOn<T>(SynchronizationContext) Sobrecargado. Suscribe y cancela la suscripción asincrónica de observadores en el contexto de sincronización especificado. (Definido por Observable).
pública Método de extensión pública SubscribeOn<T>(Control) Sobrecargado. (Definido por ControlObservable).
pública Método de extensión pública SubscribeOn<T>(Dispatcher) Sobrecargado. (Definido por DispatcherObservable).
pública Método de extensión pública SubscribeOn<T>(DispatcherScheduler) Sobrecargado. (Definido por DispatcherObservable).
pública Método de extensión pública SubscribeOn<T>(IScheduler) Sobrecargado. Suscribe y cancela la suscripción asincrónica a los observadores en el programador especificado. (Definido por Observable).
pública Método de extensión pública SubscribeOnDispatcher<T> (Definido por DispatcherObservable).
pública Método de extensión pública Sincronizar<T>() Sobrecargado. Sincroniza la secuencia observable. (Definido por Observable).
pública Método de extensión pública Sincronizar<T>(Object) Sobrecargado. Sincroniza la secuencia observable. (Definido por Observable).
pública Método de extensión pública Tomar<T> Devuelve un número especificado de valores contiguos desde el inicio de una secuencia observable. (Definido por Observable).
pública Método de extensión pública TakeLast<T> Devuelve un número especificado de elementos contiguos desde el final de una secuencia observable. (Definido por Observable).
pública Método de extensión pública TakeUntil<T, TOther> Devuelve los valores de la secuencia observable de origen hasta que la otra secuencia observable genera un valor. (Definido por Observable).
pública Método de extensión pública TakeWhile<T>(Func<T, Boolean>) Sobrecargado. Devuelve valores de una secuencia observable siempre que una condición especificada sea true y, a continuación, omite los valores restantes. (Definido por Observable).
pública Método de extensión pública TakeWhile<T(Func<T>, Int32, Boolean>) Sobrecargado. Devuelve valores de una secuencia observable siempre que una condición especificada sea true y, a continuación, omite los valores restantes. (Definido por Observable).
pública Método de extensión pública A continuación<, T, TResult> Coincide cuando la secuencia observable tiene un valor disponible y proyecta el valor. (Definido por Observable).
pública Método de extensión pública Throttle<T>(TimeSpan) Sobrecargado. Omite los valores de una secuencia observable seguida de otro valor antes del tiempo de vencimiento con el origen y dueTime especificados. (Definido por Observable).
pública Método de extensión pública Throttle<T>(TimeSpan, IScheduler) Sobrecargado. Omite los valores de una secuencia observable seguida de otro valor antes del tiempo de vencimiento con el origen, dueTime y scheduler especificados. (Definido por Observable).
pública Método de extensión pública TimeInterval<T>() Sobrecargado. Registra el intervalo de tiempo entre valores consecutivos en una secuencia observable con el origen especificado. (Definido por Observable).
pública Método de extensión pública TimeInterval<T>(IScheduler) Sobrecargado. Registra el intervalo de tiempo entre valores consecutivos en una secuencia observable con el origen y el programador especificados. (Definido por Observable).
pública Método de extensión pública Timeout<T>(TimeSpan) Sobrecargado. Devuelve la secuencia observable o timeoutException si transcurre dueTime. (Definido por Observable).
pública Método de extensión pública Timeout<T>(DateTimeOffset) Sobrecargado. Devuelve la secuencia observable o timeoutException si transcurre dueTime. (Definido por Observable).
pública Método de extensión pública Timeout<T>(TimeSpan, IObservable<T>) Sobrecargado. Devuelve la secuencia observable de origen o la otra secuencia observable si transcurre dueTime. (Definido por Observable).
pública Método de extensión pública Timeout<T>(DateTimeOffset, IObservable<T>) Sobrecargado. Devuelve la secuencia observable o timeoutException si transcurre dueTime. (Definido por Observable).
pública Método de extensión pública Timeout<T>(TimeSpan, IScheduler) Sobrecargado. Devuelve la secuencia observable o timeoutException si transcurre dueTime. (Definido por Observable).
pública Método de extensión pública Timeout<T>(DateTimeOffset, IScheduler) Sobrecargado. Devuelve la secuencia observable o timeoutException si transcurre dueTime. (Definido por Observable).
pública Método de extensión pública Timeout<T>(TimeSpan, IObservable<T>, IScheduler) Sobrecargado. Devuelve la secuencia observable de origen o la otra secuencia observable si transcurre dueTime. (Definido por Observable).
pública Método de extensión pública Timeout<T>(DateTimeOffset, IObservable<T>, IScheduler) Sobrecargado. Devuelve la secuencia observable de origen o la otra secuencia observable si transcurre dueTime. (Definido por Observable).
pública Método de extensión pública Marca de tiempo<T>() Sobrecargado. Registra la marca de tiempo de cada valor en una secuencia observable con el origen especificado. (Definido por Observable).
pública Método de extensión pública Marca de tiempo<T>(IScheduler) Sobrecargado. Registra la marca de tiempo de cada valor en una secuencia observable con el origen y el programador especificados. (Definido por Observable).
pública Método de extensión pública ToArray<T> Crea una matriz a partir de una secuencia observable. (Definido por Observable).
pública Método de extensión pública ToDictionary<T, TKey>(Func<T, TKey>) Sobrecargado. Crea un diccionario a partir de una secuencia observable según una función de selector de claves especificada. (Definido por Observable).
pública Método de extensión pública ToDictionary<T, TKey>(Func<T, TKey, IEqualityComparer<TKey>>) Sobrecargado. Crea un diccionario a partir de una secuencia observable según una función de selector de claves especificada y un comparador. (Definido por Observable).
pública Método de extensión pública ToDictionary<T, TKey, TElement>(Func<T, TKey>, Func<T, TElement>) Sobrecargado. Crea un diccionario a partir de una secuencia observable según una función de selector de claves especificada y una función de selector de elementos. (Definido por Observable).
pública Método de extensión pública ToDictionary<T, TKey, TElement>(Func<T, TKey, Func<T, TElement>, IEqualityComparer<TKey>>) Sobrecargado. Crea un diccionario a partir de una secuencia observable según una función de selector de claves especificada, un comparador y una función de selector de elementos. (Definido por Observable).
pública Método de extensión pública ToEnumerable<T> Convierte una secuencia observable en una secuencia enumerable. (Definido por Observable).
pública Método de extensión pública ToEvent<T> Expone una secuencia observable como un objeto con un evento de .NET con un origen especificado. (Definido por Observable).
pública Método de extensión pública ToList<T> Crea una lista a partir de una secuencia observable. (Definido por Observable).
pública Método de extensión pública ToLookup<T, TKey>(Func<T, TKey>) Sobrecargado. Crea una búsqueda a partir de una secuencia observable según una función de selector de claves especificada. (Definido por Observable).
pública Método de extensión pública ToLookup<T, TKey>(Func<T, TKey, IEqualityComparer<TKey>>) Sobrecargado. Crea una búsqueda a partir de una secuencia observable según una función de selector de claves especificada y un comparador. (Definido por Observable).
pública Método de extensión pública ToLookup<T, TKey, TElement>(Func<T, TKey>, Func<T, TElement>) Sobrecargado. Crea una búsqueda a partir de una secuencia observable según una función de selector de claves especificada y una función de selector de elementos. (Definido por Observable).
pública Método de extensión pública ToLookup<T, TKey, TElement>(Func<T, TKey, Func<T, TElement>, IEqualityComparer<TKey>>) Sobrecargado. Crea una búsqueda a partir de una secuencia observable según una función de selector de claves especificada, un comparador y una función de selector de elementos. (Definido por Observable).
pública Método de extensión pública ToNotifier<T> Crea una devolución de llamada de notificación a partir de un observador. (Definido por Observer).
pública Método de extensión pública ToTask<T>() Sobrecargado. Devuelve una tarea que contiene el último valor de la secuencia observable. (Definido por TaskObservableExtensions).
pública Método de extensión pública ToTask<T>(Object) Sobrecargado. Devuelve una tarea que contiene el último valor de la secuencia observable. (Definido por TaskObservableExtensions).
pública Método de extensión pública ToTask<T>(CancellationToken) Sobrecargado. Devuelve una tarea que contiene el último valor de la secuencia observable. (Definido por TaskObservableExtensions).
pública Método de extensión pública ToTask<T>(CancellationToken, Object) Sobrecargado. Devuelve una tarea que contiene el último valor de la secuencia observable. (Definido por TaskObservableExtensions).
pública Método de extensión pública Where<T>(Func<T, Boolean>) Sobrecargado. Filtra los elementos de una secuencia observable en función de un predicado. (Definido por Observable).
pública Método de extensión pública Where<T>(Func<T, Int32, Boolean>) Sobrecargado. Filtra los elementos de una secuencia observable en función de un predicado mediante la incorporación del índice del elemento. (Definido por Observable).
pública Método de extensión pública Window<T>(Int32) Sobrecargado. Proyecta cada elemento de una secuencia observable en ventanas consecutivas no superpuestas que se generan en función de la información de recuento de elementos. (Definido por Observable).
pública Método de extensión pública Ventana<T>(TimeSpan) Sobrecargado. Proyecta cada elemento de una secuencia observable en ventanas consecutivas no superpuestas que se generan en función de la información de tiempo. (Definido por Observable).
pública Método de extensión pública Window<T>(Int32, Int32) Sobrecargado. Proyecta cada elemento de una secuencia observable en cero o más ventanas que se generan en función de la información de recuento de elementos. (Definido por Observable).
pública Método de extensión pública Window<T>(TimeSpan, IScheduler) Sobrecargado. Proyecta cada elemento de una secuencia observable en ventanas consecutivas no superpuestas que se generan en función de la información de tiempo. (Definido por Observable).
pública Método de extensión pública Window<T>(TimeSpan, TimeSpan) Sobrecargado. Proyecta cada elemento de una secuencia observable en cero o más ventanas que se generan en función de la información de tiempo. (Definido por Observable).
pública Método de extensión pública Ventana<T>(TimeSpan, Int32) Sobrecargado. Proyecta cada elemento de una secuencia observable en una ventana que se completa cuando está lleno o ha transcurrido un período de tiempo determinado. (Definido por Observable).
pública Método de extensión pública Window<T>(TimeSpan, TimeSpan, IScheduler) Sobrecargado. Proyecta cada elemento de una secuencia observable en cero o más ventanas que se generan en función de la información de tiempo. (Definido por Observable).
pública Método de extensión pública Window<T>(TimeSpan, Int32, IScheduler) Sobrecargado. Proyecta cada elemento de una secuencia observable en una ventana que se completa cuando está lleno o ha transcurrido un período de tiempo determinado. (Definido por Observable).
pública Método de extensión pública Window<T, TWindowClosing>(Func<IObservable<TWindowClosing>>) Sobrecargado. Proyecta cada elemento de una secuencia observable en ventanas consecutivas no superpuestas. (Definido por Observable).
pública Método de extensión pública Window<T, TWindowOpening, TWindowClosing>(IObservable<TWindowOpening>, Func<TWindowOpening, IObservable<TWindowClosing>>) Sobrecargado. Proyecta cada elemento de una secuencia observable en cero o más ventanas. (Definido por Observable).
pública Método de extensión pública Zip<T, TSecond, TResult>(IObservable<TSecond>, Func<T, TSecond, TResult>) Sobrecargado. Combina dos secuencias observables en una secuencia observable mediante la combinación de sus elementos de forma emparejada. (Definido por Observable).
pública Método de extensión pública Zip<T, TSecond, TResult>(IEnumerable<TSecond>, Func<T, TSecond, TResult>) Sobrecargado. Combina una secuencia observable y una secuencia enumerable en una secuencia observable mediante la función selector. (Definido por Observable).

Superior

Observaciones

Un AsyncSubject publicará el elemento final recibido por su interfaz de observador cuando la interfaz de observador haya recibido una finalización. AsyncSubject también almacena en caché el elemento final de cualquier suscripción futura a su interfaz observable. Por lo tanto, las nuevas suscripciones de ese AsyncSubject también tendrán el elemento final publicado en esa suscripción.

Ejemplos

En este ejemplo, se usa AsyncSubject para suscribirse a una secuencia entera generada con el operador Range. Un AsyncSubject solo devuelve un valor cuando se completa la secuencia a la que está suscrito. Una vez completada la secuencia, AsyncSubject publicará el elemento final en la secuencia. AsyncSubject almacena en caché el elemento final. Todas las suscripciones nuevas en que AsyncSubject también tendrán el elemento final publicado en esa suscripción.

using System;
using System.Reactive.Linq;
using System.Reactive.Subjects;
using System.Reactive.Concurrency;
using System.Threading;

namespace Example
{
  class Program
  {
    static void Main()
    {
      //*******************************************************************************************************//
      //*** A subject acts similar to a proxy in that it acts as both a subscriber and a publisher          ***//
      //*** It's IObserver interface can be used to subscribe to multiple streams or sequences of data.     ***//
      //*** The data is then published through it's IObservable interface.                                  ***//
      //***                                                                                                 ***//
      //*** In this example an AsyncSubject is used to subscribe to an integer sequence from the Range      ***//
      //*** operator. An AsyncSubject only returns a value when the sequence it is subscribed to completes. ***//
      //*** Once the sequence has completed, the AsyncSubject will publish the final item in the sequence.  ***//
      //*** The AsyncSubject caches the final item. Any new subscriptions against that AsyncSubject will    ***//
      //*** also have the final item published to that subscription as well.                                ***//
      //*******************************************************************************************************//

      var intSequence = Observable.Range(0, 10, Scheduler.ThreadPool);

      AsyncSubject<int> myAsyncSubject = new AsyncSubject<int>();
      intSequence.Subscribe(myAsyncSubject);

      Thread.Sleep(1000);
      myAsyncSubject.Subscribe(i => Console.WriteLine("Final integer for subscription #1 is {0}\n", i),
                               () => Console.WriteLine("subscription #1 completed.\n"));
                                
      
      Console.WriteLine("Sleeping for 5 seconds before subscription2\n");
      Thread.Sleep(5000);

      myAsyncSubject.Subscribe(i => Console.WriteLine("Final integer for subscription #2 after 5 seconds is {0}\n", i),
                               () => Console.WriteLine("subscription #2 completed.\n"));


      Console.WriteLine("Press ENTER to exit...");
      Console.ReadLine();

      myAsyncSubject.Dispose();
    }
  }
}

El código de ejemplo generó la siguiente salida.

Final integer for subscription #1 is 9

subscription #1 completed.

Sleeping for 5 seconds before subscription2

Final integer for subscription #2 after 5 seconds is 9

subscription #2 completed.

Press ENTER to exit...

Seguridad para subprocesos

Todos los miembros estáticos públicos (Shared de Visual Basic) de este tipo son seguros para subprocesos. No se garantiza que los miembros de instancia sean seguros para subprocesos.

Consulte también

Referencia

Espacio de nombres System.Reactive.Subjects

  • Last updated on