Classe ObservableCepStream

Fornisce supporto per i sink di evento che implementano l'interfaccia IObservable.

Gerarchia di ereditarietà

System. . :: . .Object
  Microsoft.ComplexEventProcessing.Linq..::..ObservableCepStream

Spazio dei nomi  Microsoft.ComplexEventProcessing.Linq
Assembly:  Microsoft.ComplexEventProcessing.Observable (in Microsoft.ComplexEventProcessing.Observable.dll)

Sintassi

public static class ObservableCepStream

Nel tipo ObservableCepStream sono esposti i membri seguenti.

Metodi

	Nome	Descrizione
	Select< (Of < <' (TInput, TOutput> ) > > )	Proietta ogni evento di un flusso di input osservabile in un nuovo evento.
	ToEdgeObservable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ))	Converte un oggetto CepStream di eventi Edge in un sink di evento che implementa l'interfaccia IObservable. L'ordine degli eventi è FullyOrdered.
	ToEdgeObservable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder)	Converte un oggetto CepStream di eventi Edge con l'ordine di eventi specificato in un sink di evento che implementa l'interfaccia IObservable.
	ToEdgeStream< (Of < <' (TInput, TPayload> ) > > )	Converte un flusso di input osservabile in un flusso di eventi Edge e fornisce le caratteristiche temporali dell'input.
	ToIntervalObservable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ))	Converte un oggetto CepStream di eventi intervallo in un sink di evento che implementa l'interfaccia IObservable. L'ordine degli eventi è FullyOrdered.
	ToIntervalObservable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder)	Converte un oggetto CepStream di eventi intervallo con l'ordine di eventi specificato in un sink di evento che implementa l'interfaccia IObservable.
	ToIntervalStream< (Of < <' (TInput, TPayload> ) > > )	Converte un flusso di input osservabile in un flusso di eventi intervallo e fornisce le caratteristiche temporali dell'input.
	ToObservable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ))	Converte un flusso di eventi in output osservabile rimuovendo le intestazioni degli eventi e annullando gli eventi CTI.
	ToObservable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder)	Converte un flusso di eventi in output osservabile con l'ordine degli eventi specificato rimuovendo le intestazioni degli eventi e annullando gli eventi CTI.
	ToPointObservable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ))	Converte un oggetto CepStream di eventi punto in un sink di evento che implementa l'interfaccia IObservable. L'ordine degli eventi è FullyOrdered.
	ToPointObservable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder)	Converte un oggetto CepStream di eventi punto con l'ordine di eventi specificato in un sink di evento che implementa l'interfaccia IObservable.
	ToPointStream< (Of < <' (TInput, TPayload> ) > > )	Converte un flusso di input osservabile in un flusso di eventi punto e fornisce le caratteristiche temporali dell'input.
	ToStream< (Of < <' (TPayload> ) > > )(IObservable< (Of < <' (EdgeEvent< (Of < <' (TPayload> ) > > )> ) > > ), Application, AdvanceTimeSettings, String)	Converte un'origine evento che implementa l'interfaccia IObservable in un oggetto CepStream per cui è possibile eseguire query.
	ToStream< (Of < <' (TPayload> ) > > )(IObservable< (Of < <' (IntervalEvent< (Of < <' (TPayload> ) > > )> ) > > ), Application, AdvanceTimeSettings, String)	Converte un'origine evento che implementa l'interfaccia IObservable in un oggetto CepStream per cui è possibile eseguire query.
	ToStream< (Of < <' (TPayload> ) > > )(IObservable< (Of < <' (PointEvent< (Of < <' (TPayload> ) > > )> ) > > ), Application, AdvanceTimeSettings, String)	Converte un'origine evento che implementa l'interfaccia IObservable in un oggetto CepStream per cui è possibile eseguire query.
	Where< (Of < <' (TInput> ) > > )	Filtra gli eventi da un flusso di input osservabile utilizzando l'espressione filtro specificata.

In alto

Protezione dei thread

I membri static (Shared in Visual Basic) pubblici di questo tipo sono affidabili. Non è invece garantita la sicurezza dei membri dell'istanza.

Vedere anche

Riferimento

Spazio dei nomi Microsoft.ComplexEventProcessing.Linq