ObservableCepStream-Klasse

Bietet Unterstützung für Ereignissenken, die die IObservable-Schnittstelle implementieren.

Vererbungshierarchie

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

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

Syntax

public static class ObservableCepStream

Der ObservableCepStream-Typ macht folgende Elemente verfügbar.

Methoden

	Name	Beschreibung
	Select< (Of < <' (TInput, TOutput> ) > > )	Projiziert jedes Ereignis eines Observable-Eingabedatenstroms in ein neues Ereignis.
	ToEdgeObservable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ))	Konvertiert einen CepStream von Edge-Ereignissen in eine Ereignissenke, die die IObservable-Schnittstelle implementiert. Die Reihenfolge von Ereignissen ist FullyOrdered.
	ToEdgeObservable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder)	Konvertiert einen CepStream von Edge-Ereignissen mit der angegebenen Ereignisreihenfolge in eine Ereignissenke, die die IObservable-Schnittstelle implementiert.
	ToEdgeStream< (Of < <' (TInput, TPayload> ) > > )	Konvertiert einen Observable-Eingabedatenstrom in einen Datenstrom von Edge-Ereignissen und stellt die temporären Eigenschaften der Eingabe bereit.
	ToIntervalObservable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ))	Konvertiert einen CepStream von Intervallereignissen in eine Ereignissenke, die die IObservable-Schnittstelle implementiert. Die Reihenfolge von Ereignissen ist FullyOrdered.
	ToIntervalObservable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder)	Konvertiert einen CepStream von Intervallereignissen mit der angegebenen Ereignisreihenfolge in eine Ereignissenke, die die IObservable-Schnittstelle implementiert.
	ToIntervalStream< (Of < <' (TInput, TPayload> ) > > )	Konvertiert einen Observable-Eingabedatenstrom in einen Datenstrom von Intervallereignissen und stellt die temporären Eigenschaften der Eingabe bereit.
	ToObservable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ))	Konvertiert einen Datenstrom von Ereignissen in eine Observable-Ausgabe durch Entfernen von Ereignisheadern und Verwerfen von CTI-Ereignissen.
	ToObservable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder)	Konvertiert einen Datenstrom von Ereignissen in eine Observable-Ausgabe mit der angegebenen Ereignisreihenfolge durch Entfernen von Ereignisheadern und Verwerfen von CTI-Ereignissen.
	ToPointObservable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ))	Konvertiert einen CepStream von Punktereignissen in eine Ereignissenke, die die IObservable-Schnittstelle implementiert. Die Reihenfolge von Ereignissen ist FullyOrdered.
	ToPointObservable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder)	Konvertiert einen CepStream von Punktereignissen mit der angegebenen Ereignisreihenfolge in eine Ereignissenke, die die IObservable-Schnittstelle implementiert.
	ToPointStream< (Of < <' (TInput, TPayload> ) > > )	Konvertiert einen Observable-Eingabedatenstrom in einen Datenstrom von Punktereignissen und stellt die temporären Eigenschaften der Eingabe bereit.
	ToStream< (Of < <' (TPayload> ) > > )(IObservable< (Of < <' (EdgeEvent< (Of < <' (TPayload> ) > > )> ) > > ), Application, AdvanceTimeSettings, String)	Übersetzt eine Ereignisquelle, die die IObservable-Schnittstelle implementiert, in einen CepStream, der abgefragt werden kann.
	ToStream< (Of < <' (TPayload> ) > > )(IObservable< (Of < <' (IntervalEvent< (Of < <' (TPayload> ) > > )> ) > > ), Application, AdvanceTimeSettings, String)	Übersetzt eine Ereignisquelle, die die IObservable-Schnittstelle implementiert, in einen CepStream, der abgefragt werden kann.
	ToStream< (Of < <' (TPayload> ) > > )(IObservable< (Of < <' (PointEvent< (Of < <' (TPayload> ) > > )> ) > > ), Application, AdvanceTimeSettings, String)	Übersetzt eine Ereignisquelle, die die IObservable-Schnittstelle implementiert, in einen CepStream, der abgefragt werden kann.
	Where< (Of < <' (TInput> ) > > )	Filtert Ereignisse aus einem Observable-Eingabedatenstrom mithilfe des angegebenen Filterausdrucks.

Zum Anfang

Threadsicherheit

Alle öffentlichen static (Shared in Visual Basic)-Elemente dieses Typs sind Threadsicher. Für Instanzelemente wird die Threadsicherheit nicht gewährleistet.

Siehe auch

Verweis

Microsoft.ComplexEventProcessing.Linq-Namespace