Trait cubist_proxy::Pair

pub trait Pair<S, R = S, E = JsonRpcErr>: Stream<Item = Result<R, E>> + Sink<Result<S, E>, Error = FatalErr> + Send { }

A Sink/Stream pair in an RPC muxing pipeline

Implementors

impl<P, S, R, E> Pair<S, R, E> for Pwhere
    P: Stream<Item = Result<R, E>> + Sink<Result<S, E>, Error = FatalErr> + Send,