Struct toy_rpc::codec::Codec

pub struct Codec<R, W, C> {
    pub reader: R,
    pub writer: W,
    // some fields omitted
}

Default codec. Codec is re-exported as DefaultCodec when one of these feature flags is toggled (serde_bincode, serde_json, serde_cbor, serde_rmp“)

Fields

reader: R

writer: W

Implementations

impl<R, W> Codec<R, W, ConnTypeReadWrite> where
    R: AsyncRead + Send + Sync + Unpin,
    W: AsyncWrite + Send + Sync + Unpin, 

pub fn with_reader_writer(reader: R, writer: W) -> Self

impl<T> Codec<BufReader<ReadHalf<T>>, BufWriter<WriteHalf<T>>, ConnTypeReadWrite> where
    T: AsyncRead + AsyncWrite + Send + Sync + Unpin, 

pub fn new(stream: T) -> Self

impl<S, E> Codec<StreamHalf<SplitStream<S>, CanSink>, SinkHalf<SplitSink<S, WsMessage>, CanSink>, ConnTypePayload> where
    S: Stream<Item = Result<WsMessage, E>> + Sink<WsMessage> + Send + Sync + Unpin,
    E: Error + 'static, 

pub fn with_websocket(ws: WebSocketConn<S, CanSink>) -> Self

impl Codec<StreamHalf<WebSocketConnection, CannotSink>, SinkHalf<WebSocketConnection, CannotSink>, ConnTypePayload>

pub fn with_tide_websocket(
    ws: WebSocketConn<WebSocketConnection, CannotSink>
) -> Self

impl<S, E> Codec<SplitStream<S>, SplitSink<S, Message>, ConnTypePayload> where
    S: Stream<Item = Result<Message, E>> + Sink<Message>,
    E: Error, 

pub fn with_warp_websocket(ws: S) -> Self

Trait Implementations

impl<R, W> GracefulShutdown for Codec<R, W, ConnTypeReadWrite> where
    R: AsyncRead + Send + Sync + Unpin,
    W: AsyncWrite + Send + Sync + Unpin, 

fn close<'life0, 'async_trait>(
    &'life0 mut self
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

impl<R, W> GracefulShutdown for Codec<R, W, ConnTypePayload> where
    R: Send,
    W: GracefulShutdown + Send, 

fn close<'life0, 'async_trait>(
    &'life0 mut self
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait,