pub trait Connection {
type Rx: Stream<Item = Result<ChannelMessage>> + Unpin;
type Tx: Sink<BlockMessage, Error = Error> + Unpin;
// Required methods
fn get_rx_mut(&mut self) -> &mut Self::Rx;
fn get_tx_mut(&mut self) -> &mut Self::Tx;
}
Expand description
Leaky abstraction to hold connection to a command server.