Trait capnp_rpc::Connection[−][src]

pub trait Connection<VatId> {
    fn get_peer_vat_id(&self) -> VatId;

    fn new_outgoing_message(
        &mut self, 
        first_segment_word_size: u32
    ) -> Box<dyn OutgoingMessage>;

    fn receive_incoming_message(
        &mut self
    ) -> Promise<Option<Box<dyn IncomingMessage>>, Error>;

    fn shutdown(&mut self, result: Result<()>) -> Promise<(), Error>;
}

Required methods

fn get_peer_vat_id(&self) -> VatId[src]

fn new_outgoing_message(
    &mut self,
    first_segment_word_size: u32
) -> Box<dyn OutgoingMessage>[src]

fn receive_incoming_message(
    &mut self
) -> Promise<Option<Box<dyn IncomingMessage>>, Error>[src]

Waits for a message to be received and returns it. If the read stream cleanly terminates, returns None. If any other problem occurs, returns an Error.

fn shutdown(&mut self, result: Result<()>) -> Promise<(), Error>[src]

Loading content...

Implementors

Loading content...