Struct scaproust::transport::async::AsyncPipe

pub struct AsyncPipe<S: AsyncPipeStub + 'static> { /* fields omitted */ }

Methods

impl<S: AsyncPipeStub + 'static> AsyncPipe<S>

fn new(stub: S, pids: (u16, u16)) -> AsyncPipe<S>

Trait Implementations

impl<S: AsyncPipeStub> Pipe for AsyncPipe<S>

fn ready(&mut self, ctx: &mut Context, events: Ready)

fn open(&mut self, ctx: &mut Context)

fn close(&mut self, ctx: &mut Context)

fn send(&mut self, ctx: &mut Context, msg: Rc<Message>)

fn recv(&mut self, ctx: &mut Context)