ICepObservable(T) 接口

扩展 IObservable<T> 接口,让您可以为可观察的事件源指定查询名称和说明。

命名空间:  Microsoft.ComplexEventProcessing.Linq
程序集:  Microsoft.ComplexEventProcessing.Observable(在 Microsoft.ComplexEventProcessing.Observable.dll 中)

语法

public interface ICepObservable<T> : IObservable<T>

类型参数

  • T
    事件的类型

ICepObservable<(Of <(<'T>)>)> 类型公开以下成员。

方法

  名称 说明
公共方法 Subscribe(IObserver< (Of < <' (T> ) > > )) (从 IObservable< (Of < ( <'T> ) > ) > 继承。)
公共方法 Subscribe(IObserver< (Of < <' (T> ) > > ), String, String) 扩展 IObservable<T> 接口,让您可以为可观察的事件源指定查询名称和说明。

页首

扩展方法

  名称 说明
公共扩展方法 Select< (Of < <' (TInput, TOutput> ) > > ) 将可观察输入流的每个事件投影到新事件。 (由 ObservableCepStream 定义。)
公共扩展方法 ToEdgeStream< (Of < <' (T, TPayload> ) > > ) 将可观察的输入流转换为边缘事件流,并提供输入的临时特征。 (由 ObservableCepStream 定义。)
公共扩展方法 ToIntervalStream< (Of < <' (T, TPayload> ) > > ) 将可观察的输入流转换为间隔事件流,并提供输入的临时特征。 (由 ObservableCepStream 定义。)
公共扩展方法 ToPointStream< (Of < <' (T, TPayload> ) > > ) 将可观察的输入流转换为点事件流,并提供输入的临时特征。 (由 ObservableCepStream 定义。)
公共扩展方法 Where< (Of < <' (TInput> ) > > ) 使用指定的筛选表达式筛选可观察输入流中的事件。 (由 ObservableCepStream 定义。)

页首

注释

有关 ICepObservable<T> 扩展的接口的详细信息,请参阅 documentation for the IObservable<T> interface in the MSDN Library

请参阅

参考

Microsoft.ComplexEventProcessing.Linq 命名空间