Migrate types to reactive-streams 0.4.0 (M1)
Add CompletableQueue and its support in PersistentQueue. Mainly used for Streaming purpose.
Add support for CompletableQueue in StreamSubscription
Change signature for Stream.consume to return the wrapping output action. Useful for catching error.
Change signature for Stream.flushWhen to return the wrapping output action. Useful for catching error.
Change signature for Stream.timeout to return the wrapping output action. Useful for catching error.
Change signature for Stream.connect to return the wrapping output action. Useful for action specific methods, extensions and fluent-style programming
Refactor PersistentQueue to generate less objects (no more Function to handle get/remove/offer
Few tweaks to dispatcher in order to support parallel features in Stream and expose some insight (current capacity, ordering guarantee...).
Stream now forgive use of non ordered Dispatcher (using Dispatcher.supportsOrdering(). For concurrency support, a new couple of transformers have been added to Stream : parallel()/merge()
Fix P --> C --> P in Stream (e.g. stream.parallel().merge() ) deadlock by submitting the task to the next iteration (tail recurse)