Function connection_utils::channel_into_framed_stream

pub fn channel_into_framed_stream<T: Serialize + DeserializeOwned + Send + Debug + Display + 'static, TAsyncDuplex: AsyncWrite + Send + ?Sized + 'static>(
    stream: SplitSink<Framed<Pin<Box<TAsyncDuplex>>, GenericCodec<T>>, T>
) -> (Sender<T>, JoinHandle<Result<()>>)

Create a mpsc channel that points to the framed stream.