Compartir a través de

Clase BehaviorSubject<T>

Representa un valor que cambia con el tiempo.

Jerarquía de herencia

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

espacio de nombres : System.Reactive.Subjects
ensamblado de : System.Reactive (en System.Reactive.dll)

Sintaxis

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

'Usage
Dim instance As BehaviorSubject(Of T)

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

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

[<SealedAttribute>]
type BehaviorSubject<'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 BehaviorSubject<T> expone los siguientes miembros.

Constructores

  Nombre Descripción
método Public BehaviorSubject<T> Inicializa una nueva instancia de la clase BehaviorSubject<T> que crea un asunto que almacena en caché su último valor y comienza con el valor especificado.

Arriba

Métodos

  Nombre Descripción
método Public Dispose Cancelar la suscripción de todos los observadores y liberar recursos.
método Public equals (Se hereda de objeto).
método protected Finalizar (Se hereda de objeto).
método Public GetHashCode (Se hereda de objeto).
método Public GetType (Se hereda de objeto).
método protected memberwiseClone (Se hereda de objeto).
método Public OnCompleted Notifica a todos los observadores suscritos del final de la secuencia.
método Public onError Notifica a todos los observadores suscritos con la excepción.
método Public OnNext Notifica a todos los observadores suscritos el valor.
método Public suscribirse Suscribe un observador al asunto.
método Public toString (Se hereda de objeto).

Arriba

Métodos de extensión

  Nombre Descripción
método de extensión pública <T>(Func<T, T, T>) Sobrecargado. Aplica una función de acumulador a través de una secuencia observable. (Definido por observable).
método de extensión pública <T agregado, 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).
método de extensión pública todas las> T de< Determina si todos los elementos de una secuencia observable cumplen una condición. (Definido por observable).
método de extensión pública Amb<T> Propaga la secuencia observable que reacciona primero con la primera y segunda secuencia especificadas. (Definido por observable).
método de extensión pública Y<T, TRight> Coincide cuando ambas secuencias observables tienen un valor disponible. (Definido por observable).
método de extensión pública <T>() Sobrecargado. Determina si una secuencia observable contiene elementos. (Definido por observable).
método de extensión pública Cualquier>T de<(Func<T,>booleano ) Sobrecargado. Determina si todos los elementos de una secuencia observable cumplen una condición. (Definido por observable).
método de extensión pública asObservable<T> Oculta la identidad de una secuencia observable. (Definido por observable).
método de extensión pública AsObserver<T> Oculta la identidad de un observador. (Definido por Observer).
método de extensión pública asQbservable<T> Convierte una secuencia observable en una secuencia observable consultable. (Definido por Qbservable).
método de extensión pública AssertEqual<T> (Definido por extensiones de ).
método de extensión pública Búfer<T>(Int32) Sobrecargado. Indica cada elemento de una secuencia observable en búferes consecutivos no superpuestos que se generan en función de la información de recuento de elementos. (Definido por observable).
método de extensión pública de búfer deT (TimeSpan) Sobrecargado. Indica cada elemento de una secuencia observable en búferes consecutivos no superpuestos que se generan en función de la información de tiempo. (Definido por observable).
método de extensión pública búfer<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).
método de extensión pública de búfer deT (TimeSpan, IScheduler) Sobrecargado. Indica cada elemento de una secuencia observable en búferes consecutivos no superpuestos que se generan en función de la información de tiempo. (Definido por observable).
método de extensión pública Búfer<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).
método de extensión pública Tbuffer (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).
método de extensión pública Búfer<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).
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).
método de extensión pública buffer<T, TBufferClosing>(func<IObservable<TBufferClosing>>) Sobrecargado. Indica cada elemento de una secuencia observable en búferes consecutivos no superpuestos. (Definido por observable).
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 consecutivos que no se superponen. (Definido por observable).
método de extensión pública catch<T>(IObservable<T>) Sobrecargado. Continúa una secuencia observable finalizada por una excepción con la siguiente secuencia observable. (Definido por observable).
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).
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).
método de extensión pública Concat<T> Concatena dos secuencias observables. (Definido por observable).
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).
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 especificado< T>. (Definido por observable).
método de extensión pública Count<T> Devuelve un int32 que representa el número total de elementos de una secuencia observable. (Definido por observable).
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).
método de extensión pública >T (T)<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).
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).
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).
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).
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).
método de extensión pública >T<() Sobrecargado. Devuelve una secuencia observable que contiene solo elementos distintos con un origen especificado. (Definido por observable).
método de extensión pública <T>(IEqualityComparer<T>) Sobrecargado. Devuelve una secuencia observable que contiene solo elementos distintos según el comparador. (Definido por observable).
método de extensión pública distinct<T, TKey>(Func<T, TKey>) Sobrecargado. Devuelve una secuencia observable que contiene solo elementos distintos según keySelector. (Definido por observable).
método de extensión pública Distinct<T, TKey>(Func<T, TKey>, IEqualityComparer<TKey>) Sobrecargado. Devuelve una secuencia observable que contiene solo elementos distintos según keySelector. (Definido por observable).
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).
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).
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).
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).
método de extensión pública <T>(Action<T>) Sobrecargado. Invoca una acción para cada elemento de la secuencia observable. (Definido por observable).
método de extensión pública <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).
método de extensión pública >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).
método de extensión pública <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).
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 una terminación correcta o excepcional de la secuencia observable. (Definido por observable).
método de extensión pública ElementAt<T> Devuelve el elemento en un índice especificado de una secuencia. (Definido por observable).
método de extensión pública ElementAtOrDefault<T> Devuelve el elemento de un índice especificado en una secuencia o un valor predeterminado si el índice está fuera del intervalo. (Definido por observable).
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 por una excepción. (Definido por observable).
método de extensión pública T() Sobrecargado. Devuelve el primer elemento de una secuencia observable con un origen especificado. (Definido por observable).
método de extensión pública First<T>(Func<T, booleano>) Sobrecargado. Devuelve el primer elemento de una secuencia observable que coincide con el predicado. (Definido por observable).
método de extensión pública >T<FirstOrDefault () () Sobrecargado. Devuelve el primer elemento de una secuencia observable o un valor predeterminado si no se encuentra ningún valor. (Definido por observable).
método de extensión pública FirstOrDefault<T>(Func<T, booleano>) 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).
método de extensión pública Foo<T, R> (Definido por MyExt).
método de extensión pública forEach<T> Invoca una acción para cada elemento de la secuencia observable y bloquea hasta que finaliza la secuencia. (Definido por observable).
método de extensión pública > T<GetEnumerator Devuelve un enumerador que enumera todos los valores de la secuencia observable. (Definido por observable).
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).
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 un comparador de selector de claves especificados. (Definido por observable).
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).
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).
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).
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 un comparador de selector de claves especificados. (Definido por observable).
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).
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).
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).
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).
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).
método de extensión pública último<T>() Sobrecargado. Devuelve el último elemento de una secuencia observable con un origen especificado. (Definido por observable).
método de extensión pública última<T>(Func<T,>booleano ) Sobrecargado. Devuelve el último elemento de una secuencia observable que coincide con el predicado. (Definido por observable).
método de extensión pública T LastOrDefault () Sobrecargado. Devuelve el último elemento de la secuencia observable o un valor predeterminado si no se encuentra ningún valor. (Definido por observable).
método de extensión pública >T<LastOrDefault (Func<T,>booleano ) 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).
método de extensión pública latest<T> Muestra el valor más reciente en una secuencia observable. (Definido por observable).
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).
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).
método de extensión pública <T>() Sobrecargado. Devuelve el elemento máximo de una secuencia observable. (Definido por observable).
método de extensión pública T(TT) Sobrecargado. Devuelve el valor máximo de una secuencia observable según el comparador especificado. (Definido por observable).
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).
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).
método de extensión pública >T de<(>de<Tobservable ) Sobrecargado. Combina una secuencia observable de secuencias observables en una secuencia observable. (Definido por observable).
método de extensión pública mergeT (IObservableT, IScheduler) Sobrecargado. Combina dos secuencias observables en una sola secuencia observable. (Definido por observable).
método de extensión pública > > >de mínimo de<T () Sobrecargado. Devuelve el elemento mínimo de una secuencia observable. (Definido por observable).
método de extensión pública <T>(IComparer<T>) Sobrecargado. Devuelve el valor mínimo de una secuencia observable según el comparador especificado. (Definido por observable).
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).
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).
método de extensión pública MostRecent<T> Muestra el valor más reciente en una secuencia observable. (Definido por observable).
método de extensión pública multidifusión<T,>TResult (<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).
método de extensión pública <T, TIntermediate, TResult>(Func<ISubject<T, TIntermediate>>, Func<IObservable<TIntermediate>, IObservable<TResult>>) Sobrecargado. Devuelve una secuencia observable que contiene los elementos de una secuencia producida por la multidifusión de la secuencia de origen dentro de una función selectora. (Definido por observable).
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).
método de extensión pública ObserveOn<T>(SynchronizationContext) Sobrecargado. Notifique de forma asincrónica a los observadores en el contexto de sincronización especificado. (Definido por observable).
método de extensión pública >T<(Control) de ObserveOn Sobrecargado. (Definido por ControlObservable).
método de extensión pública < <T>(Distribuidor) Sobrecargado. (Definido por DispatcherObservable).
método de extensión pública >T de ObserveOn (DispatcherScheduler)< Sobrecargado. (Definido por DispatcherObservable).
método de extensión pública ObserveOn<T>(IScheduler) Sobrecargado. Notifique asincrónicamente a los observadores en el programador especificado. (Definido por observable).
método de extensión pública ObserveOnDispatcher<T> (Definido por DispatcherObservable).
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).
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).
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 con initialValue. (Definido por observable).
método de extensión pública Publish<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).
método de extensión pública publicar<T, TResult>(<<>Tobservable<func,<TResult>>, T) Sobrecargado. Devuelve una secuencia observable conectable que comparte una sola suscripción a la secuencia subyacente y comienza con initialValue. (Definido por observable).
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).
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).
método de extensión pública repetir<T>() Sobrecargado. Repite la secuencia observable indefinidamente. (Definido por observable).
método de extensión pública repetir<T>(Int32) Sobrecargado. Repite la secuencia observable indefinidamente. (Definido por observable).
método de extensión pública reproducción<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).
método de extensión pública < <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).
método de extensión pública <T>(Int32) Sobrecargado. Devuelve una secuencia observable conectable que comparte una sola suscripción a las notificaciones bufferSize de reproducción de secuencias subyacentes. (Definido por observable).
método de extensión pública >T<replay (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).
método de extensión pública >T<replay (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).
método de extensión pública <T>(Int32, IScheduler) Sobrecargado. Devuelve una secuencia observable conectable que comparte una sola suscripción a las notificaciones bufferSize de reproducción de secuencias subyacentes. (Definido por observable).
método de extensión pública <T>(Int32, TimeSpan) Sobrecargado. Devuelve una secuencia observable conectable que comparte una sola suscripción con el búfer de reproducción de secuencias subyacenteSize notificaciones dentro de la ventana. (Definido por observable).
método de extensión pública replay<T>(Int32, TimeSpan, IScheduler) Sobrecargado. Devuelve una secuencia observable conectable que comparte una sola suscripción con el búfer de reproducción de secuencias subyacenteSize notificaciones dentro de la ventana. (Definido por observable).
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 con el valor inicial. (Definido por observable).
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 que reproduce todas las notificaciones. (Definido por observable).
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 que reproduce todas las notificaciones dentro de la ventana. (Definido por observable).
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 notificaciones. (Definido por observable).
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 que reproduce todas las notificaciones dentro de la ventana. (Definido por observable).
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 notificaciones. (Definido por observable).
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 notificaciones dentro de la ventana. (Definido por observable).
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 notificaciones dentro de la ventana. (Definido por observable).
método de extensión pública deT de de reintento () Sobrecargado. Repite la secuencia observable de origen hasta que finaliza correctamente. (Definido por observable).
método de extensión pública reintentar<T>(Int32) Sobrecargado. Repite la secuencia observable de origen hasta que finaliza correctamente. (Definido por observable).
método de extensión pública < >T de ejemplo (TimeSpan) Sobrecargado. Muestra la secuencia observable en cada intervalo. (Definido por observable).
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).
método de extensión pública ejemplo de<T,>de TSample (<<TSample>) Sobrecargado. Muestra la secuencia observable en tics de muestreo con el origen y el muestreador especificados. (Definido por observable).
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).
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).
método de extensión pública Seleccionar<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).
método de extensión pública Seleccionar<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).
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).
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).
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).
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).
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).
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 aplana las secuencias observables resultantes en una secuencia observable. (Definido por observable).
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).
método de extensión pública SequenceEqual<T>(IObservable<T>, IEqualityComparer<T>) Sobrecargado. Determina si dos secuencias son iguales comparando los elementos de forma emparejada mediante un comparador de igualdad especificado. (Definido por observable).
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).
método de extensión pública >T de<único (Func<T,>booleano ) 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).
método de extensión pública SingleOrDefaultT() Sobrecargado. Devuelve el único elemento de una secuencia observable o un valor predeterminado si la secuencia observable está vacía. (Definido por observable).
método de extensión pública SingleOrDefault<T>(Func<T, booleano>) 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).
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).
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).
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).
método de extensión pública SkipWhile<T>(Func<T, booleano>) 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).
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).
método de extensión pública StartWithTT[]) Sobrecargado. Antepone una secuencia de valores a una secuencia observable con el origen y los valores especificados. (Definido por observable).
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).
método de extensión pública < <T>() Sobrecargado. Evalúa la secuencia observable con un origen especificado. (Definido por ObservableExtensions).
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).
método de extensión pública Suscribir<T>(Action<T>, Action<Exception>) Sobrecargado. Suscribe un controlador de elementos y un controlador de excepciones a una secuencia observable. (Definido por ObservableExtensions).
método de extensión pública Suscribir<T>(Action<T>, Action) Sobrecargado. Suscribe un controlador de elementos y un controlador de finalización a una secuencia observable. (Definido por ObservableExtensions).
método de extensión pública Suscribir<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).
método de extensión pública subscribeOnT(SynchronizationContext) de Sobrecargado. Suscribe y cancela la suscripción asincrónica a los observadores en el contexto de sincronización especificado. (Definido por observable).
método de extensión pública <T>(Control) Sobrecargado. (Definido por ControlObservable).
método de extensión pública SubscribeOn<T>(Dispatcher) Sobrecargado. (Definido por DispatcherObservable).
método de extensión pública subscribeOn<T>(DispatcherScheduler) Sobrecargado. (Definido por DispatcherObservable).
método de extensión pública >T<(IScheduler) Sobrecargado. Suscribe y cancela la suscripción asincrónica a los observadores en el programador especificado. (Definido por observable).
método de extensión pública SubscribeOnDispatcher<T> (Definido por DispatcherObservable).
método de extensión pública Sincronizar<>T () Sobrecargado. Sincroniza la secuencia observable. (Definido por observable).
método de extensión pública Sincronizar<T>(objeto) Sobrecargado. Sincroniza la secuencia observable. (Definido por observable).
método de extensión pública Tomar<T> Devuelve un número especificado de valores contiguos desde el principio de una secuencia observable. (Definido por observable).
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).
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).
método de extensión pública TakeWhile<T>(Func<T, booleano>) 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).
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).
método de extensión pública <T, TResult> Coincide cuando la secuencia observable tiene un valor disponible y proyecta el valor. (Definido por observable).
método de extensión pública limitación de<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).
método de extensión pública limitación de<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).
método de extensión pública timeIntervalT() Sobrecargado. Registra el intervalo de tiempo entre valores consecutivos en una secuencia observable con el origen especificado. (Definido por observable).
método de extensión pública >T<TimeInterval (IScheduler) Sobrecargado. Registra el intervalo de tiempo entre valores consecutivos en una secuencia observable con el origen y el programador especificados. (Definido por observable).
método de extensión pública tiempo de espera<>T (TimeSpan) Sobrecargado. Devuelve la secuencia observable o timeoutException si transcurre dueTime. (Definido por observable).
método de extensión pública tiempo de espera<T>(DateTimeOffset) Sobrecargado. Devuelve la secuencia observable o timeoutException si transcurre dueTime. (Definido por observable).
método de extensión pública tiempo de espera<T>(TimeSpan, IObservable<T>) Sobrecargado. Devuelve la secuencia observable de origen o la otra secuencia observable si transcurre dueTime. (Definido por observable).
método de extensión pública tiempo de espera<T>(DateTimeOffset, IObservable<T>) Sobrecargado. Devuelve la secuencia observable o timeoutException si transcurre dueTime. (Definido por observable).
método de extensión pública >T<T (TimeSpan, IScheduler) Sobrecargado. Devuelve la secuencia observable o timeoutException si transcurre dueTime. (Definido por observable).
método de extensión pública tiempo de espera<T>(DateTimeOffset, IScheduler) Sobrecargado. Devuelve la secuencia observable o timeoutException si transcurre dueTime. (Definido por observable).
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).
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).
método de extensión pública marca de tiempo<>T () Sobrecargado. Registra la marca de tiempo de cada valor de una secuencia observable con el origen especificado. (Definido por observable).
método de extensión pública marca de tiempo<T>(IScheduler) Sobrecargado. Registra la marca de tiempo de cada valor de una secuencia observable con el origen y el programador especificados. (Definido por observable).
método de extensión pública ToArray<T> Crea una matriz a partir de una secuencia observable. (Definido por observable).
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).
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).
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).
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 selectora de elementos. (Definido por observable).
método de extensión pública toEnumerable<T> Convierte una secuencia observable en una secuencia enumerable. (Definido por observable).
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).
método de extensión pública ToList<T> Crea una lista a partir de una secuencia observable. (Definido por observable).
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).
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).
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).
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).
método de extensión pública ToNotifier<T> Crea una devolución de llamada de notificación desde un observador. (Definido por Observer).
método de extensión pública TT() Sobrecargado. Devuelve una tarea que contiene el último valor de la secuencia observable. (Definido por TaskObservableExtensions).
método de extensión pública toTask<T>(objeto) Sobrecargado. Devuelve una tarea que contiene el último valor de la secuencia observable. (Definido por TaskObservableExtensions).
método de extensión pública >T<toTask (CancellationToken) Sobrecargado. Devuelve una tarea que contiene el último valor de la secuencia observable. (Definido por TaskObservableExtensions).
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).
método de extensión pública Where<T>(Func<T, Boolean>) Sobrecargado. Filtra los elementos de una secuencia observable basada en un predicado. (Definido por observable).
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).
método de extensión pública ventana<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).
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).
método de extensión pública ventana<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).
método de extensión pública ventana<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).
método de extensión pública ventana de (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).
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).
método de extensión pública ventana<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).
método de extensión pública ventana<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).
método de extensión pública ventana<T, TWindowClosing>(func<IObservable<TWindowClosing>>) Sobrecargado. Proyecta cada elemento de una secuencia observable en ventanas consecutivas que no se superponen. (Definido por observable).
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).
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).
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 selectora. (Definido por observable).

Arriba

Observaciones

Un sujeto actúa de forma similar a un proxy en que actúa como suscriptor y como publicador. Su interfaz IObserver se puede usar para suscribirse a varios flujos o secuencias de datos. Los datos se publican a través de la interfaz IObservable.

Un BehaviorSubject almacena en búfer el último elemento que publicó a través de su interfaz IObservable. Si no se ha publicado ningún elemento a través de su interfaz IObservable, el elemento inicial proporcionado en el constructor es el elemento almacenado en búfer actualmente. Cuando se realiza una suscripción a la interfaz IObservable de BehaviorSubject, la secuencia publicada comienza con el elemento almacenado en búfer actualmente.

No se almacena en búfer ni se publica ningún elemento de un BehaviorSubject una vez que su interfaz IObserver recibe una finalización.

Ejemplos

En este ejemplo se muestra behaviorSubject. En el ejemplo se usa el operador Interval para publicar un entero en una secuencia entera cada segundo. El operador Take completará la secuencia después de publicar 10 enteros. Esta es la secuencia a la que se suscribe behaviorSubject.

Se crean dos suscripciones para la interfaz IObservable de BehaviorSubject para mostrar cómo publica los datos.

  • suscripción n.º 1 : esta suscripción se iniciará al principio y mostrará el valor inicial almacenado en búfer del constructor (-9) en la secuencia.

  • suscripción n.º 2: esta suscripción se iniciará después de 5 segundos de suspensión. Esta suscripción muestra que la secuencia comienza con el elemento almacenado actualmente en búfer.

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.                                   ***//
      //***                                                                                                  ***//
      //*** A BehaviorSubject buffers the last item it published through its IObservable interface. If no    ***//
      //*** item has been published through its IObservable interface then the initial item provided in the  ***//
      //*** constructor is the current buffered item. When a subscription is made to the BehaviorSubject's   ***//
      //*** IObservable interface, the sequence published begins with the currently buffered item.           ***//
      //***                                                                                                  ***//
      //*** No items are buffered or published from a BehaviorSubject once its IObserver interface receives  ***//
      //*** a completion.                                                                                    ***//
      //***                                                                                                  ***//
      //*** In this example, we use the Interval operator to publish an integer to a integer sequence every  ***//
      //*** second. The sequence will be completed by the Take operator after 10 integers are published.     ***//
      //*** This will be the sequence that the BehaviorSubject subscribes to.                                ***//
      //***                                                                                                  ***//
      //*** We will create 2 subscriptions to the BehaviorSubject's IObservable interface to show how it     ***//
      //*** publishes it's data.                                                                             ***//
      //***                                                                                                  ***//
      //*** Subscription #1 : This subscription will start at the very beginning and will show the initial   ***//
      //***                   buffered value from the constructor (-9) in the sequence.                      ***//
      //***                                                                                                  ***//
      //*** Subscription #2 : This subscription will start after a 5 sec. sleep showing the sequence starts  ***//
      //***                   with the currently buffered item.                                              ***//
      //********************************************************************************************************//

      BehaviorSubject<long> myBehaviorSubject = new BehaviorSubject<long>((-9));
      Observable.Interval(TimeSpan.FromSeconds(1), Scheduler.ThreadPool).Take(10).Subscribe(myBehaviorSubject);

      
      //********************************************************************************************************//
      //*** Subscription #1 : This subscription will start at the very beginning and will show the initial   ***//
      //***                   buffered value from the constructor (-9) in the sequence.                      ***//
      //********************************************************************************************************//

      EventWaitHandle wait1 = new EventWaitHandle(false, EventResetMode.ManualReset);
      myBehaviorSubject.Subscribe(x => Console.WriteLine("Subscription #1 observes : " + x),
                                  () => 
                                  {
                                    Console.WriteLine("Subscription #1 completed.");
                                    wait1.Set();
                                  });


      //********************************************************************************************************//
      //*** Subscription #2 : This subscription will start after a 5 sec. sleep showing the sequence starts  ***//
      //***                   with the currently buffered item.                                              ***//
      //********************************************************************************************************//
    
      Thread.Sleep(5000);
      EventWaitHandle wait2 = new EventWaitHandle(false, EventResetMode.ManualReset);
      myBehaviorSubject.Subscribe(x => Console.WriteLine("{0,30}Subscription #2 observes : {1}", " ", x), 
                                  () => 
                                  {
                                    Console.WriteLine("{0,30}Subscription #2 completed.", " ");
                                    wait2.Set();
                                  });


      //**************************************************//
      // *** Wait for completion on both subscriptions ***//
      //**************************************************//

      WaitHandle.WaitAll(new WaitHandle[] { wait1, wait2 });
      myBehaviorSubject.Dispose();

      Console.WriteLine("\nPress ENTER to exit...");
      Console.ReadLine();
    }
  }
}

La siguiente salida del código de ejemplo muestra las suscripciones superpuestas.

Subscription #1 observes : -9
Subscription #1 observes : 0
Subscription #1 observes : 1
Subscription #1 observes : 2
Subscription #1 observes : 3
Subscription #1 observes : 4
                              Subscription #2 observes : 4
Subscription #1 observes : 5
                              Subscription #2 observes : 5
Subscription #1 observes : 6
                              Subscription #2 observes : 6
Subscription #1 observes : 7
                              Subscription #2 observes : 7
Subscription #1 observes : 8
                              Subscription #2 observes : 8
Subscription #1 observes : 9
                              Subscription #2 observes : 9
Subscription #1 completed.
                              Subscription #2 completed.

Press ENTER to exit...

Seguridad de subprocesos

Los miembros estáticos públicos (compartidos en 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