Support stream abstraction for emitting messages to different streams and subscribing to input from specific streams.