Fix issues linked to greater buffer+timeout in test leading to deadlock condition because the dynamic merge wasn't protected by a reactive-pull subscription
 Add Streams.create(Publisher) , former Streams.defer(Publisher), and make it uses a reactive pull subscription. It works nicely with lambda and closures.
 Add Stream.consume(nextConsumer, errorConsumer?, completeConsumer?) alias for java8 and groovy love
 Improve more generics
 Fully hydrate defer(T...) to defer(T, T etc...)
 Improve various docs
 Fix issues with dispatchOn
 Improve InnerSubscriber in merging operation to track pending request when above capacity (derived from master action capacity / number of inner subscribers)
 Make Stream standard operation final to make them slightly more fast at lookup and avoid confusion those ones are derived in Action
Fix issues linked to greater buffer+timeout in test leading to deadlock condition because the dynamic merge wasn't protected by a reactive-pull subscription
 Add Streams.create(Publisher) , former Streams.defer(Publisher), and make it uses a reactive pull subscription. It works nicely with lambda and closures.
 Add Stream.consume(nextConsumer, errorConsumer?, completeConsumer?) alias for java8 and groovy love
 Improve more generics
 Fully hydrate defer(T...) to defer(T, T etc...)
 Improve various docs
 Fix issues with dispatchOn
 Improve InnerSubscriber in merging operation to track pending request when above capacity (derived from master action capacity / number of inner subscribers)
 Make Stream standard operation final to make them slightly more fast at lookup and avoid confusion those ones are derived in Action

Add Streams.range, Streams.empty
Future to Stream, Streams.defer(future)
Various fixes
Clean on Complete to improve perfs and avoid leak
Use firehose for cold streams to improve perfs
Misc fixes
Make Base Stream stateless.
Move Action State and broadcastXXX into Action
Move Subscriptions into rx.subscription
Remove alias for Streams.xxx( Environment, Dispatcher?) in favor of stream.dispatchOn(Environment, Dispatcher)
Add Streams.fail()
Javadoc improvement, rename streamSubscription to reflect the pattern used
Fix last tests, optimize state to be null by default
Fix test
check != null timeout
increase future test timeout
Bulk update copyright statement to current company name and year.
Fix race condition, update benchmarks
Fix parallelTest for now (race condition with Streams.parallel)
Add Streams.timer and Streams.period
Fix resolution check
Minor tweak to trigger a build.
Change to using a "real" HashWheelTimer
Stream.connectAnd() Stream.subscribeAnd() to chain consume from the same origin stream.
Fix pending demand on HotStream
Refactor Action.drain() to Stream.drain()
Change getRootTimer to getTimer
Fix timeout issue in test
rename every() to sample() and first() to sampleFirst()
rename limit() to take and takeUntil()
repurpose timeout to be a terminal Action
add timing condition to batchAction, buffer, window and sample* now benefit from it
add onOverflowDrop
misc fixes
Fix HashWheelTimer issue with Stream
Fix tests
Fix tests
Much dispatching
avoid double error on timeout