Struct tiny_rpc::io::Transport

pub struct Transport { /* fields omitted */ }

Implementations

impl Transport

pub fn from_streamed<T>(io: T) -> Self where
    T: AsyncRead + AsyncWrite + Send + Sync + 'static, 

pub fn from_streamed_pair<R, W>(reader: R, writer: W) -> Self where
    R: AsyncRead + Send + Sync + 'static,
    W: AsyncWrite + Send + Sync + 'static, 

pub fn from_framed<T>(io: T) -> Self where
    T: Stream<Item = Result<RpcFrame>> + Sink<RpcFrame, Error = Error> + Send + Sync + 'static, 

pub fn from_framed_pair<T, U>(stream: T, sink: U) -> Self where
    T: Stream<Item = Result<RpcFrame>> + Send + Sync + 'static,
    U: Sink<RpcFrame, Error = Error> + Send + Sync + 'static, 

pub fn new_local() -> (Self, Self)

pub fn split(
    self
) -> (GenericStream<Result<RpcFrame>>, GenericSink<RpcFrame, Error>)