connection-utils 0.8.0

Connection related utilities.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

use std::pin::Pin;

use tokio_util::codec::Framed;
use tokio::io::{AsyncRead, AsyncWrite};
use serde::{Serialize, de::DeserializeOwned};

use crate::{codecs::GenericCodec, types::TFramedAsyncDuplex};

/// Creates a new framed stream out of a channel.
pub fn create_framed_stream<
    T: Serialize + DeserializeOwned,
    TAsyncDuplex: AsyncRead + AsyncWrite + Send + Unpin + ?Sized + 'static,
>(
    stream: Box<TAsyncDuplex>,
) -> TFramedAsyncDuplex<T, TAsyncDuplex> {
    return Framed::new(
        Pin::new(stream),
        GenericCodec::<T>::new(),
    );
}