Improve groupBy to pass the key to downstream subscribers
Change debug() method to return a StreamVisitor that provides for toString() and toMap() export
StreamUtils now exports String traces as well as Map recollection of the graph flow. A typical use-case is to provide for json metrics.
Change BatchAction to drain upstream to max capacity if downstream request was lower than its capacity
Reduce Promise scope to its core value: retrieve a single signal from a stream.
Add Stream.promise() operation to create a promise from a stream
Add Promise.stream() operation to create a stream from a promise
Remove Pipeline interface since Promise is not a publisher anymore
Add Stream#toBlockingQueue() to consume results from a Stream directly
Add Stream#toList() to wait for stream completion and collect result directly
Add Stream#finallyTo() to observe error or complete signals
Update Streams.utils to debug more accurately promises
Add Stream#connect(Subscriber) to match the Action alias
Add Stream#dispatchOn to assign a new dispatcher on a new connected stream