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 = 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)

Parameters

  • 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.

  • 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.

Type Parameters

  • TPayload
    Type of the event payload.

See Also

ToStream Overload
ObservableCepStream Class
Microsoft.ComplexEventProcessing.Linq Namespace

Return to top