ServiceTransport

jetstream::prelude::server

Trait ServiceTransport 

Source 
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
    + Unpin
where
    P: Protocol,
{
    // Required method
    fn context(&self) -> Context;
}

Required Methods§

Source

fn context(&self) -> Context

Implementors§

Source§

impl<P, T> ServiceTransport<P> for T
where P: Protocol, T: 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 + Unpin + Contextual,