ObservableCepStream.ToPointStream<TInput, TPayload> Method (IObservable<TInput>, Application, Expression<Func<TInput, PointEvent<TPayload>>>, AdvanceTimeSettings, String)

 

Converts an observable input stream to a stream of point events, and provides the temporal characteristics of the input.

Namespace:   Microsoft.ComplexEventProcessing.Linq
Assembly:  Microsoft.ComplexEventProcessing.Observable (in Microsoft.ComplexEventProcessing.Observable.dll)

Syntax

public static CepStream<TPayload> ToPointStream<TInput, TPayload>(
    this IObservable<TInput> source,
    Application application,
    Expression<Func<TInput, PointEvent<TPayload>>> selector,
    AdvanceTimeSettings advanceTimeSettings = null,
    string streamName = null
)
public:
generic<typename TInput, typename TPayload>
[ExtensionAttribute]
static CepStream<TPayload>^ ToPointStream(
    IObservable<TInput>^ source,
    Application^ application,
    Expression<Func<TInput, PointEvent<TPayload>^>^>^ selector,
    AdvanceTimeSettings^ advanceTimeSettings = null,
    String^ streamName = null
)
static member ToPointStream<'TInput, 'TPayload> : 
        source:IObservable<'TInput> *
        application:Application *
        selector:Expression<Func<'TInput, PointEvent<'TPayload>>> *
        advanceTimeSettings:AdvanceTimeSettings = null *
        streamName:string = null -> CepStream<'TPayload>
<ExtensionAttribute>
Public Shared Function ToPointStream(Of TInput, TPayload) (
    source As IObservable(Of TInput),
    application As Application,
    selector As Expression(Of Func(Of TInput, PointEvent(Of TPayload))),
    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 of point events.

Type Parameters

  • TInput
    Type of the input.
  • TPayload
    Type of the event payload.

See Also

ObservableCepStream Class
Microsoft.ComplexEventProcessing.Linq Namespace

Return to top