ObservableCepStream.ToStream<TPayload> 方法 (IObservable<EdgeEvent<TPayload>>, Application, AdvanceTimeSettings, String)

 

將實作 IObservable 介面的事件來源轉譯為可以查詢的 CepStream

命名空間:   Microsoft.ComplexEventProcessing.Linq
組件:  Microsoft.ComplexEventProcessing.Observable (在 Microsoft.ComplexEventProcessing.Observable.dll 中)

語法

public static CepStream<TPayload> ToStream<TPayload>(
    this IObservable<EdgeEvent<TPayload>> source,
    Application application,
    AdvanceTimeSettings advanceTimeSettings = null,
    string streamName = null
)
public:
generic<typename TPayload>
[ExtensionAttribute]
static CepStream<TPayload>^ ToStream(
    IObservable<EdgeEvent<TPayload>^>^ source,
    Application^ application,
    AdvanceTimeSettings^ advanceTimeSettings = null,
    String^ streamName = null
)
static member ToStream<'TPayload> : 
        source:IObservable<EdgeEvent<'TPayload>> *
        application:Application *
        advanceTimeSettings:AdvanceTimeSettings = null *
        streamName:string = null -> CepStream<'TPayload>
<ExtensionAttribute>
Public Shared Function ToStream(Of TPayload) (
    source As IObservable(Of EdgeEvent(Of TPayload)),
    application As Application,
    advanceTimeSettings As AdvanceTimeSettings,
    streamName As String
) As CepStream(Of TPayload)

參數

  • source
    可觀察輸入資料流。
  • application
    主控事件來源的應用程式執行個體。 此參數不可以是 null。 應用程式必須屬於透過呼叫其中一個 Server.Create 多載所產生的內嵌伺服器。
  • advanceTimeSettings
    暫時的輸入特性。
  • streamName
    資料流的名稱。

    資料流名稱支援使用 AdvanceTimeImportSettings 在資料流之間「匯入」CTI 事件。 這些設定需要使用者指出做為匯入 CTI 事件之來源的輸入資料流名稱。

傳回值

Type: Microsoft.ComplexEventProcessing.Linq.CepStream<TPayload>

可用來撰寫查詢之可觀察事件來源的資料流定義。

類型參數

  • TPayload
    事件裝載的類型。

請參閱

ToStream 超載
ObservableCepStream 類別
Microsoft.ComplexEventProcessing.Linq 命名空間

回到頁首