Stream utilities for working with concurrent channels.
Writes the contents of an input stream to a channel until the input stream yields end-of-stream.
Concurrently merges a list of
InputStreams, combining values in the
order they become available.
Note: does not forward individual end-of-stream notifications, the produced stream does not yield end-of-stream until all of the input streams have finished.
This traps exceptions in each concurrent thread and re-raises them in the current thread.