pub type RxStream<P> = Pin<Box<dyn Stream<Item = Result<Frame<<P as Protocol>::Response>>> + Send + Sync>>;
#[repr(transparent)]pub struct RxStream<P> { /* private fields */ }