Closed asubb closed 4 years ago
We need to add support for merging two different streams by specifying the function to merge with. Also that function may return something different than was specified as an input type.
stream1.merge(stream2) { x, y -> x + y }
The signature of the merge function is:
(T?, T?) -> R
Implemented in https://github.com/asubb/wavebeans/pull/23
We need to add support for merging two different streams by specifying the function to merge with. Also that function may return something different than was specified as an input type.
The signature of the merge function is: