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