pub type ReadStream = FramedRead<RecvStream, MessageCodec>;
pub struct ReadStream { /* private fields */ }