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