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


Метод ObservableExtensions.Subscribe<TSource> (IObservable<TSource>, Action<TSource>, Action<Exception>)

Подписывает обработчик элементов и обработчик исключений на наблюдаемую последовательность.

Пространство имен:System
Сборки: System.Reactive (в System.Reactive.dll)

Синтаксис

'Declaration
<ExtensionAttribute> _
Public Shared Function Subscribe(Of TSource) ( _
    source As IObservable(Of TSource), _
    onNext As Action(Of TSource), _
    onError As Action(Of Exception) _
) As IDisposable
'Usage
Dim source As IObservable(Of TSource)
Dim onNext As Action(Of TSource)
Dim onError As Action(Of Exception)
Dim returnValue As IDisposable

returnValue = source.Subscribe(onNext, _
    onError)
public static IDisposable Subscribe<TSource>(
    this IObservable<TSource> source,
    Action<TSource> onNext,
    Action<Exception> onError
)
[ExtensionAttribute]
public:
generic<typename TSource>
static IDisposable^ Subscribe(
    IObservable<TSource>^ source, 
    Action<TSource>^ onNext, 
    Action<Exception^>^ onError
)
static member Subscribe : 
        source:IObservable<'TSource> * 
        onNext:Action<'TSource> * 
        onError:Action<Exception> -> IDisposable 
JScript does not support generic types and methods.

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

  • TSource

Параметры

  • source
    Тип: System.IObservable<TSource>
    Наблюдаемая последовательность для подписки.
  • onNext
    Тип: System.Action<TSource>
    Действие, вызываемое для каждого элемента в наблюдаемой последовательности.
  • Onerror
    Тип: Исключение System.Action<>
    Действие, вызываемое при исключительном завершении наблюдаемой последовательности.

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

Тип: System.IDisposable
Объект IDisposable, используемый для отмены подписки на наблюдаемую последовательность.

Примечание об использовании

В Visual Basic и C# этот метод можно вызвать как метод экземпляра для любого объекта типа IObservable<TSource>. При вызове метода для экземпляра следует опускать первый параметр. Дополнительные сведения см. в разделе или .

См. также:

Ссылка

Класс ObservableExtensions

Перегрузка подписки

Пространство имен System