通过

针对 StreamInsight 中的 IObservable 和 IEnumerable 的 API 支持

  • 项目

本主题总结了 StreamInsight 中支持实现 IObservable 或 IEnumerable 接口的事件源和接收器的 API 功能。

针对可观察和可枚举的输入的 API 支持

以下 API 功能支持实现 IObservable 或 IEnumerable 接口的事件源。

创建输入

创建绑定输入

使用 CepStream<(Of <(<'TPayload>)>)> 类的 Create 方法的以下重载之一，创建绑定到某个应用程序的输入流。

从可观察的输入创建输入

使用 ObservableCepStream 类的 ToStream 方法的以下重载之一，将 IObservable 事件源转换为输入流。

从可枚举的输入创建输入

使用 CepStream 类的 ToStream 方法的以下重载之一，将 IEnumerable 事件源转换为输入流。

描述临时特征

使用 AdvanceTimeSettings 类的以下帮助器之一，描述源数据的临时特征。

将输入映射到点事件、间隔事件和边缘事件

在传递给 ToStream 方法的重载的表达式中，使用以下方法将输入数据映射到点事件、间隔事件或边缘事件。

将输入映射到点事件

在传递给 ToStream 方法的重载的表达式中，使用 PointEvent 或 PointEvent<(Of <(<'TPayload>)>)> 类的以下方法将输入数据映射到点事件和相应的 CTI 事件。

将输入映射到间隔事件

在传递给 ToStream 方法的重载的表达式中，使用 IntervalEvent 或 IntervalEvent<(Of <(<'TPayload>)>)> 类的以下方法将输入数据映射到间隔事件和相应的 CTI 事件。

创建边缘事件

在传递给 ToStream 方法的重载的表达式中，使用 EdgeEvent 或 EdgeEvent<(Of <(<'TPayload>)>)> 类的以下方法将输入数据映射到边缘事件和相应的 CTI 事件。

针对可观察和可枚举的输出的 API 支持

以下 API 功能支持实现 IObservable 或 IEnumerable 接口的事件接收器。

创建输出

使用 ObservableCepStream 类的以下方法之一，将事件流转换为特定事件形状的 IObservable 输出。

使用 CepStream 类的以下方法之一，将事件流转换为特定事件形状的 IEnumerable 输出。

映射输出

映射可观察的输出

使用 ObservableCepStream 的以下方法映射“可观察的”输出。

映射可枚举的输出

使用 CepStream 的以下方法映射“可枚举的”输出。

扩展的事件接收器接口

上述用于创建和筛选输出的方法可返回事件接收器，这些事件接收器可实现能扩展 IObservable 和 IEnumerable 基础接口的接口。这些扩展接口尤其能支持您通过提供查询名称来进行调试操作。