pub trait CanReceive: Stream<Item = Result<Self::Frame, Self::Error>> + Sealed { type Frame: Frame; type Error; }
can