Trait tiny_rpc::io::IntoRpcStream

pub trait IntoRpcStream<T>: Stream + Sized {
    fn map(item: Self::Item) -> Result<T, Error>;

    fn into_rpc_stream(self) -> RpcStream<T, Self> { ... }
}

Required methods

fn map(item: Self::Item) -> Result<T, Error>

Loading content...

Provided methods

fn into_rpc_stream(self) -> RpcStream<T, Self>

Loading content...

Implementors

impl<T, U, E, S> IntoRpcStream<T> for S where
    U: Into<T>,
    E: Into<Error>,
    S: Stream<Item = Result<U, E>> + StreamSealed<T>, 

fn map(item: Self::Item) -> Result<T, Error>

Loading content...