stream synchronize

Synchronize

library operator
ID: f0c81ff9-e7d7-45a5-92d9-8c09ec939bf8
Emits all collected values for multiple streams at once in a given interval.

Implementation

The implementation of Synchronize makes use of the following 5 operators.

2
Collect window
Collects items from a stream until released.
1
Clock
Regularly emits a trigger at a given time interval.
2
Release window
Releases windows of items collected before.