core passing test and starting updating other modules
Remove expansive traces, fix module merging and benchmark with reactor#reactive-stream branch
Update benchmark with latest reactive streams changes
Remove Flush,
Add merge() / parallel() support : WIP
Improve perfs : WIP
Change warming iterations as environment doesn't shutdown between warmup and iterations, not leaving a chance for dispatchers to properly finish their job.
WIP Parallel/Merge Issues
Todo: Optimizations
MergeAction.InnerSubscriber#onComplete now cleans reference from FanInSubscription
MergeAction takes every slot from a given Dispatcher by default
Test improvements, lazy environment configuration and temp. recursive task clean removal
Fix CallbackAction and  tests
minor improvements for consistency
Fix capacity issue for dynamic merge action, optimize queue for subscription
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
New fix for #358
Amend pendingNextSignals handling in Action
Amend mergeAction to use capacity instead of pending signals for initial substream request
+ zip() : coordinate upstreams to produce a mapped value  of the most recent input from each stream
+ join() : coordinate upstreams to produce a list of the most recent input from each stream
Fix duplicate demand in CallbackAction (resulting in de-sync in ParallelAction downstream demand)
Merge reactor-benchmarks
Various fixes, improve parallel action to find next available substream on a round robin fashion.
Add Streams.parallel for MPMS scenarios ( no intermediate Stream between producers and subscribers )
Add Dispatcher#inContext() method to request an arbitrary dispatcher context, e.g. if the current thread is a dispatcher assigned one.
Make ParallelStream yield for data when request() is called in order to hint the next dispatched data to use that ready stream.
Fix FlatMap onComplete memory leak
Switch default ring buffer to YieldWaitStrategy
Fix Retry
Revert the default strategy to blockingWait and introduce AgileWaitStrategy (as a default), it is capable of switching wait strategy dynamically using nervous() and calm()

Introduce Parallel#monitorLatency to avoid lock-in by a single substream using processing time as a variable to hint the next substream
Fix promise super typing - (when with Tuple)
Add Streams#merge #zip and #join