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 命名空間
回到頁首