Trait Pipe

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

Simple communication channel to send/recv objects over a synchronous stream. NOTE: This synchronous specialization is mainly useful when wrapped w/ the PyPipe struct, which is also synchronous (via Python).

Required Methods

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

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

Implementations on Foreign Types

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

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

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

Implementors

impl<T: Serialize + DeserializeOwned> Pipe<T> for StreamPipe