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 命名空間