ObservableCepStream.ToStream<TPayload> Method (IObservable<EdgeEvent<TPayload>>, Application, AdvanceTimeSettings, String)
Translates an event source that implements the IObservable interface into a CepStream that can be queried.
Namespace: Microsoft.ComplexEventProcessing.Linq
Assembly: Microsoft.ComplexEventProcessing.Observable (in Microsoft.ComplexEventProcessing.Observable.dll)
Syntax
public static CepStream<TPayload> ToStream<TPayload>(
this IObservable<EdgeEvent<TPayload>> source,
Application application,
AdvanceTimeSettings advanceTimeSettings,
string streamName
)
Type Parameters
- TPayload
Type of the event payload.
Parameters
- source
Type: System.IObservable<EdgeEvent<TPayload>>
The observable input stream.
- application
Type: Microsoft.ComplexEventProcessing.Application
Application instance that hosts the event source. This parameter cannot be null. The application must belong to an embedded server that was generated by calling one of the overloads of Server.Create.
- advanceTimeSettings
Type: Microsoft.ComplexEventProcessing.AdvanceTimeSettings
Temporal characteristics of the input.
- streamName
Type: System.String
Name of the stream.
A stream name supports “importing” CTI events from one stream to another using AdvanceTimeImportSettings. These settings require the user to indicate the name of the input stream from which the CTI events are imported.
Return Value
Type: Microsoft.ComplexEventProcessing.Linq.CepStream<TPayload>
A stream definition for the observable event source that can be used to compose queries.
Usage Note
In Visual Basic and C#, you can call this method as an instance method on any object of type IObservable<EdgeEvent<TPayload>>. When you use instance method syntax to call this method, omit the first parameter. For more information, see https://msdn.microsoft.com/en-us/library/bb384936(v=sql.105) or https://msdn.microsoft.com/en-us/library/bb383977(v=sql.105).