jetstream::prelude

Trait ClientTransport

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

Implementors

impl<P, T> ClientTransport

for Twhere P: Protocol, T: Sink<Frame<

::Request>, Error = Error> + Stream<Item = Result<Frame<

::Response>, Error>> + Send + Sync + Unpin,