Compartilhar via


Interface ICepObservable(T)

Estende a interface IObservable<T> para permitir que você especifique um nome de consulta e uma descrição para uma origem de evento observável.

Namespace:  Microsoft.ComplexEventProcessing.Linq
Assembly:  Microsoft.ComplexEventProcessing.Observable (em Microsoft.ComplexEventProcessing.Observable.dll)

Sintaxe

public interface ICepObservable<T> : IObservable<T>

Parâmetros de tipo

  • T
    Tipo do evento

O tipo ICepObservable<(Of <(<'T>)>)> expõe os membros a seguir.

Métodos

  Nome Descrição
Método público Subscribe(IObserver< (Of < <' (T> ) > > )) (Herdado de IObservable< (Of < ( <'T> ) > ) >.)
Método público Subscribe(IObserver< (Of < <' (T> ) > > ), String, String) Estende a interface IObservable<T> para permitir que você especifique um nome de consulta e uma descrição para uma origem de evento observável.

Início

Métodos de extensão

  Nome Descrição
Método de extensão público Select< (Of < <' (TInput, TOutput> ) > > ) Projeta cada evento de um fluxo de entrada observável em um novo evento. (Definido por ObservableCepStream.)
Método de extensão público ToEdgeStream< (Of < <' (T, TPayload> ) > > ) Converte um fluxo de entrada observável em um fluxo de eventos de borda, e fornece as características temporais da entrada. (Definido por ObservableCepStream.)
Método de extensão público ToIntervalStream< (Of < <' (T, TPayload> ) > > ) Converte um fluxo de entrada observável em um fluxo de eventos de intervalo, e fornece as características temporais da entrada. (Definido por ObservableCepStream.)
Método de extensão público ToPointStream< (Of < <' (T, TPayload> ) > > ) Converte um fluxo de entrada observável em um fluxo de eventos pontuais, e fornece as características temporais da entrada. (Definido por ObservableCepStream.)
Método de extensão público Where< (Of < <' (TInput> ) > > ) Filtra eventos de um fluxo de entrada observável usando a expressão de filtro especificada. (Definido por ObservableCepStream.)

Início

Comentários

Para obter mais informações sobre a interface que ICepObservable<T> estende, consulte a documentation for the IObservable<T> interface in the MSDN Library. (em inglês)

Consulte também

Referência

Namespace Microsoft.ComplexEventProcessing.Linq