Trait Connection

Source

pub trait Connection {
    type Io: AsyncRead + AsyncWrite + Unpin;
    type Future: Future<Output = Result<(ResponseHead, Payload), SendRequestError>>;
    type TunnelFuture: Future<Output = Result<(ResponseHead, Framed<Self::Io, ClientCodec>), SendRequestError>>;

    // Required methods
    fn protocol(&self) -> Protocol;
    fn send_request<B: MessageBody + 'static, H: Into<RequestHeadType>>(
        self,
        head: H,
        body: B,
    ) -> Self::Future;
    fn open_tunnel<H: Into<RequestHeadType>>(
        self,
        head: H,
    ) -> Self::TunnelFuture;
}