stream::channel() support and read/decode pipelining