jetstream::prelude

Trait ServiceTransport

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

Implementors

impl<P, T> ServiceTransport

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

::Response>, Error =

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

::Request>,

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