共用方式為

StreamInsight 對於 IObservable 和 IObserver 介面的 API 支援

  • 發行項

此主題將摘要說明 StreamInsight 中支援實作 IObservable 或 IEnumerable 介面之事件來源和接收的 API 功能。

可觀察和可列舉輸入的 API 支援

下列 API 功能支援實作 IObservable 或 IEnumerable 介面的事件來源。

建立輸入

建立繫結輸入

您可以使用 CepStream<(Of <(<'TPayload>)>)> 類別之 Create 方法的下列其中一個多載，建立繫結至應用程式的輸入資料流。

根據可觀察的輸入建立輸入

您可以使用 ObservableCepStream 類別之 ToStream 方法的下列其中一個多載，將 IObservable 事件來源轉譯成輸入資料流。

根據可列舉的輸入建立輸入

您可以使用 CepStream 類別之 ToStream 方法的下列其中一個多載，將 IEnumerable 事件來源轉譯成輸入資料流。

描述暫時特性

您可以使用 AdvanceTimeSettings 類別的下列其中一個 Helper，描述來源資料的暫時特性。

將輸入對應至點、間隔和邊緣事件

您可以在傳遞給 ToStream 方法之多載的運算式中使用下列方法，藉以將輸入資料對應至點、間隔或邊緣事件。

將輸入對應至點事件

您可以在傳遞給 ToStream 方法之多載的運算式中使用 PointEvent 或 PointEvent<(Of <(<'TPayload>)>)> 類別的下列方法，藉以將輸入資料對應至點事件和對應的 CTI 事件。

將輸入對應至間隔事件

您可以在傳遞給 ToStream 方法之多載的運算式中使用 IntervalEvent 或 IntervalEvent<(Of <(<'TPayload>)>)> 類別的下列方法，藉以將輸入資料對應至間隔事件和對應的 CTI 事件。

建立邊緣事件

您可以在傳遞給 ToStream 方法之多載的運算式中使用 EdgeEvent 或 EdgeEvent<(Of <(<'TPayload>)>)> 類別的下列方法，藉以將輸入資料對應至邊緣事件和對應的 CTI 事件。

可觀察和可列舉輸出的 API 支援

下列 API 功能支援實作 IObservable 或 IEnumerable 介面的事件接收。

建立輸出

您可以使用 ObservableCepStream 類別的下列其中一個方法，將事件的資料流轉譯成特定事件圖形的 IObservable 輸出。

您可以使用 CepStream 類別的下列其中一個方法，將事件的資料流轉譯成特定事件圖形的 IEnumerable 輸出。

對應輸出

對應可觀察的輸出

您可以使用 ObservableCepStream 的下列方法來對應可觀察的輸出。

對應可列舉的輸出

您可以使用 CepStream 的下列方法來對應可列舉的輸出。

事件接收的擴充介面

上述用於建立和篩選輸出的方法會傳回實作介面的事件接收，而這些介面會擴充基底 IObservable 和 IEnumerable 介面。特別是，擴充介面可讓您針對偵錯目的提供查詢名稱。