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