Provide a primitive to implement streams synchronization #28
Description
The synchronized consumer does not fit terribly well in the dataflow primitives.
We need to find out how to make a stream progress only when another commit log provides a watermark.
Is it something we should express outside of the dataflow primitives ?