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