ToIntervalObservable(TPayload) 方法 (CepStream(TPayload), StreamEventOrder)
将具有指定事件顺序的间隔事件的 CepStream 转换为用于实现 IObservable 接口的事件接收器。
命名空间: Microsoft.ComplexEventProcessing.Linq
程序集: Microsoft.ComplexEventProcessing.Observable(在 Microsoft.ComplexEventProcessing.Observable.dll 中)
语法
public static ICepObservable<IntervalEvent<TPayload>> ToIntervalObservable<TPayload>(
this CepStream<TPayload> stream,
StreamEventOrder streamEventOrder
)
类型参数
- TPayload
事件负载的类型。
参数
- stream
类型:Microsoft.ComplexEventProcessing.Linq. . :: . .CepStream< (Of < ( <'TPayload> ) > ) >
完全绑定的事件源,可从中创建可观察的事件接收器。
- streamEventOrder
类型:Microsoft.ComplexEventProcessing. . :: . .StreamEventOrder
用于指定如何对事件排序的枚举值之一。
返回值
类型:Microsoft.ComplexEventProcessing.Linq. . :: . .ICepObservable< (Of < ( <'IntervalEvent< (Of < ( <'TPayload> ) > ) >> ) > ) >
支持观察的事件接收器。
用法说明
在 Visual Basic 和 C# 中,您可以对 CepStream< (Of < ( <'TPayload> ) > ) > 类型的任何对象将此方法作为实例方法调用。在您使用实例方法语法调用此方法时,将忽略第一个参数。有关详细信息,请参阅https://msdn.microsoft.com/zh-cn/library/bb384936(v=sql.105)或https://msdn.microsoft.com/zh-cn/library/bb383977(v=sql.105)。
注释
调用可观察的事件接收器的 Subscribe 方法可初始化和启动查询。当释放订阅时,将删除此查询。
ICepObservable<(Of <(<'T>)>)> 接口包含 Subscribe 的重载,使您可以指定查询的名称和说明。这些附加属性可用于进行调试。
有关在事件的负载中支持的数据类型的详细信息,请参阅创建事件类型。