Поделиться через

Объединения

  • Статья

В примерах из этого раздела показано, как объединять события из разных потоков, используя операцию объединения. Операция объединения принимает два входных потока и объединяет события, чтобы создать единый выходной поток событий. Объединение работает с двумя потоками 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);