Remove stream pauses from streaming tests
Add more type inference friendly version of forkOnNext().
Repackage Stream classes
Add some Javadoc
Fix checkstyle
Bust up DefaultExecController, and make the execution error and completion handlers immutable (i.e. specified at the start of the execution).
Some cleanup in NettyHandlerAdapter.
Some cleanup around the response transmitter.
Detect when a request hasn't been responded to and send back an empty 500 response and log a warning (#418).