jetstream_rpc

Trait ClientTransport

pub trait ClientTransport<P: Protocol>:
    Sink<Frame<P::Request>, Error = Error>
    + Stream<Item = Result<Frame<P::Response>, Error>>
    + Send
    + Sync
    + Unpin { }

Implementors

impl<P: Protocol, T> ClientTransport

for Twhere Self: Sized, T: Sink<Frame<P::Request>, Error = Error> + Stream<Item = Result<Frame<P::Response>, Error>> + Send + Sync + Unpin,