Trait capnp_rpc::Connection
source · pub trait Connection<VatId> {
// Required methods
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
fn new_outgoing_message( &mut self, first_segment_word_size: u32 ) -> Box<dyn OutgoingMessage>
sourcefn receive_incoming_message(
&mut self
) -> Promise<Option<Box<dyn IncomingMessage>>, Error>
fn receive_incoming_message( &mut self ) -> Promise<Option<Box<dyn IncomingMessage>>, Error>
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.