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 | |
|---|---|---|
.gif "Öffentliche Methode") .gif "Statisches Element") |
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.