ObservableCepStream.Where<TInput> Method (ICepObservable<TInput>, Expression<Func<TInput, Boolean>>)

Filters events from an observable input stream using the specified filter expression.

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

Syntax

public static ICepObservable<TInput> Where<TInput>(
    this ICepObservable<TInput> source,
    Expression<Func<TInput, bool>> predicate
)

public:
generic<typename TInput>
[ExtensionAttribute]
static ICepObservable<TInput>^ Where(
    ICepObservable<TInput>^ source,
    Expression<Func<TInput, bool>^>^ predicate
)

static member Where<'TInput> : 
        source:ICepObservable<'TInput> *
        predicate:Expression<Func<'TInput, bool>> -> ICepObservable<'TInput>

<ExtensionAttribute>
Public Shared Function Where(Of TInput) (
    source As ICepObservable(Of TInput),
    predicate As Expression(Of Func(Of TInput, Boolean))
) As ICepObservable(Of TInput)

Parameters

• source
  Type: Microsoft.ComplexEventProcessing.Linq.ICepObservable<TInput>

  The observable source to be filtered. This parameter cannot be null.

• predicate
  Type: System.Linq.Expressions.Expression<Func<TInput, Boolean>>

  The selection predicate. This parameter cannot be null.

Return Value

Type: Microsoft.ComplexEventProcessing.Linq.ICepObservable<TInput>

The observable stream of filtered events..

Type Parameters

• TInput
  Type of the source.

See Also

ObservableCepStream Class
Microsoft.ComplexEventProcessing.Linq Namespace

Return to top