+str Various cleanups of internal streams architecture

Round 1:
 - Factored out input and output receive blocks using a switchable PartialFunction
 - reduced surface of ActorProcessorImpl
 - removed lazy vals of TransferStates
 - somewhat cleaner shutdown process
 - robustified some of the tests