ObservableCepStream 類別
為實作 IObservable 介面的事件接收提供支援。
繼承階層
System. . :: . .Object
Microsoft.ComplexEventProcessing.Linq..::..ObservableCepStream
命名空間: Microsoft.ComplexEventProcessing.Linq
組件: Microsoft.ComplexEventProcessing.Observable (在 Microsoft.ComplexEventProcessing.Observable.dll 中)
語法
public static class ObservableCepStream
ObservableCepStream 型別公開下列成員。
方法
|
Select< (Of < <' (TInput, TOutput> ) > > ) |
將可觀察輸入資料流的每一個事件投射到新的事件。 |
|
ToEdgeObservable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > )) |
將邊緣事件的 CepStream 轉換成實作 IObservable 介面的事件接收。事件的順序為 FullyOrdered。 |
|
ToEdgeObservable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder) |
以指定的事件順序將邊緣事件的 CepStream 轉換成實作 IObservable 介面的事件接收。 |
|
ToEdgeStream< (Of < <' (TInput, TPayload> ) > > ) |
將可觀察輸入資料流轉換為邊緣事件資料流,並提供暫時的輸入特性。 |
|
ToIntervalObservable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > )) |
將間隔事件的 CepStream 轉換成實作 IObservable 介面的事件接收。事件的順序為 FullyOrdered。 |
|
ToIntervalObservable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder) |
以指定的事件順序將間隔事件的 CepStream 轉換成實作 IObservable 介面的事件接收。 |
|
ToIntervalStream< (Of < <' (TInput, TPayload> ) > > ) |
將可觀察輸入資料流轉換為間隔事件資料流,並提供暫時的輸入特性。 |
|
ToObservable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > )) |
藉由移除事件標頭及捨棄 CTI 事件的方式將事件資料流轉換為可觀察輸出。 |
|
ToObservable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder) |
藉由移除事件標頭及捨棄 CTI 事件的方式,以指定的事件順序將事件資料流轉換為可觀察輸出。 |
|
ToPointObservable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > )) |
將時間點事件的 CepStream 轉換成實作 IObservable 介面的事件接收。事件的順序為 FullyOrdered。 |
|
ToPointObservable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder) |
以指定的事件順序將時間點事件的 CepStream 轉換成實作 IObservable 介面的事件接收。 |
|
ToPointStream< (Of < <' (TInput, TPayload> ) > > ) |
將可觀察輸入資料流轉換為時間點事件資料流,並提供暫時的輸入特性。 |
|
ToStream< (Of < <' (TPayload> ) > > )(IObservable< (Of < <' (EdgeEvent< (Of < <' (TPayload> ) > > )> ) > > ), Application, AdvanceTimeSettings, String) |
將實作 IObservable 介面的事件來源轉譯為可以查詢的 CepStream。 |
|
ToStream< (Of < <' (TPayload> ) > > )(IObservable< (Of < <' (IntervalEvent< (Of < <' (TPayload> ) > > )> ) > > ), Application, AdvanceTimeSettings, String) |
將實作 IObservable 介面的事件來源轉譯為可以查詢的 CepStream。 |
|
ToStream< (Of < <' (TPayload> ) > > )(IObservable< (Of < <' (PointEvent< (Of < <' (TPayload> ) > > )> ) > > ), Application, AdvanceTimeSettings, String) |
將實作 IObservable 介面的事件來源轉譯為可以查詢的 CepStream。 |
|
Where< (Of < <' (TInput> ) > > ) |
使用指定的篩選運算式來篩選可觀察輸入資料流中的事件。 |
上層
執行緒安全性
這個型別的任何公用 static (在 Visual Basic 中為 Shared) 成員都是執行緒安全的。並不是所有的執行個體成員都保證可以用於所有的執行緒。
請參閱
參考
Microsoft.ComplexEventProcessing.Linq 命名空間