联合

本主题中的示例演示如何通过联合运算组合不同流中的事件。联合运算接收两个输入流,并组合这些事件以生成单个输出事件流。联合针对两个 CepStream<T> 流执行运算,并将这两个流合并为一个 CepStream<T> 流。

示例

以下示例将 stream1 中的所有事件与 stream2 中的事件组合到一个流中。

var unioned = stream1.Union(stream2);

以下示例演示了如何通过执行一元联合调用的级联来联合两个以上的流。第一次调用将 stream1 中的事件与 stream2 中的事件进行组合。生成的流 unionTmp 随后与 stream3 组合以生成最终的输出流 unionFinal。

var unionTmp = stream1.Union(stream2);
var unionFinal = unionTmp.Union(stream3);