Trait tokio_hglib::Connection

pub trait Connection: Send + 'static {
    type Rx: Stream<Item = ChannelMessage, Error = Error> + Send;
    type Tx: Sink<SinkItem = BlockMessage, SinkError = Error> + Send;
    type Aux: Send;
    fn from_parts(rx: Self::Rx, tx: Self::Tx, aux: Self::Aux) -> Self;
    fn into_parts(self) -> (Self::Rx, Self::Tx, Self::Aux);
}

Leaky abstraction to hold connection to a command server.

Associated Types

type Rx: Stream<Item = ChannelMessage, Error = Error> + Send

type Tx: Sink<SinkItem = BlockMessage, SinkError = Error> + Send

type Aux: Send

Required Methods

fn from_parts(rx: Self::Rx, tx: Self::Tx, aux: Self::Aux) -> Self

fn into_parts(self) -> (Self::Rx, Self::Tx, Self::Aux)

Implementors