Enum Pipe 

pub enum Pipe {
    Local {
        rx: Receiver<Envelope>,
        tx: Sender<Envelope>,
        initiator: bool,
    },
    Piped {
        pipe: Pin<Box<dyn TransportPipe<Error = TransportError, Item = Result<Bytes, TransportError>> + Send>>,
        initiator: bool,
    },
    PipedWithStreams {
        pipe: Pin<Box<dyn TransportPipe<Error = TransportError, Item = Result<Bytes, TransportError>> + Send>>,
        initiator: bool,
        streams: Option<Arc<ConnectionStreams>>,
    },
}

Variants

Local

Fields

rx: Receiver<Envelope>

tx: Sender<Envelope>

initiator: bool

Piped

Fields

pipe: Pin<Box<dyn TransportPipe<Error = TransportError, Item = Result<Bytes, TransportError>> + Send>>

initiator: bool

PipedWithStreams

Fields

pipe: Pin<Box<dyn TransportPipe<Error = TransportError, Item = Result<Bytes, TransportError>> + Send>>

initiator: bool

streams: Option<Arc<ConnectionStreams>>

Implementations

impl Pipe

pub fn piped_with_streams( pipe: Pin<Box<dyn TransportPipe<Error = TransportError, Item = Result<Bytes, TransportError>> + Send>>, initiator: bool, streams: Arc<ConnectionStreams>, ) -> Pipe