stream_multiplexer
// FIXME: ...