pub type DynStream = Pin<Box<dyn Stream<Item = Result<BytesMut, Error>> + Sync + Send>>;
struct DynStream {}