Trait AsyncPipe

pub trait AsyncPipe<T> {
    // Required methods
    fn send(&mut self, val: T) -> impl Future<Output = Result<()>>;
    fn recv(&mut self) -> impl Future<Output = Result<T>>;
}

Simple communication channel to send/recv objects over an async stream.

Required Methods

fn send(&mut self, val: T) -> impl Future<Output = Result<()>>

fn recv(&mut self) -> impl Future<Output = Result<T>>

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementations on Foreign Types

impl<T: Send + Sync + 'static> AsyncPipe<T> for (UnboundedSender<T>, UnboundedReceiver<T>)

async fn send(&mut self, val: T) -> Result<()>

async fn recv(&mut self) -> Result<T>

Implementors

impl<T: Serialize + DeserializeOwned> AsyncPipe<T> for AsyncStreamPipe