Struct capnp_rpc::twoparty::VatNetwork

pub struct VatNetwork<T>
where
    T: AsyncRead + 'static + Unpin,
{ /* private fields */ }

A vat network with two parties, the client and the server.

Implementations

impl<T> VatNetwork<T>

where T: AsyncRead + Unpin,

pub fn new<U>( input_stream: T, output_stream: U, side: Side, receive_options: ReaderOptions ) -> Self

where U: AsyncWrite + 'static + Unpin,

Creates a new two-party vat network that will receive data on input_stream and send data on output_stream.

side indicates whether this is the client or the server side of the connection. This has no effect on the data sent over the connection; it merely exists so that RpcNetwork::bootstrap knows whether to return the local or the remote bootstrap capability. VatId parameters like this one will make more sense once we have vat networks with more than two parties.

The options in receive_options will be used when reading the messages that come in on input_stream.

Trait Implementations

impl<T> VatNetwork<Side> for VatNetwork<T>

where T: AsyncRead + Unpin,

fn connect(&mut self, host_id: VatId) -> Option<Box<dyn Connection<VatId>>>

Returns None if hostId refers to the local vat.

fn accept(&mut self) -> Promise<Box<dyn Connection<VatId>>, Error>

Waits for the next incoming connection and return it.

fn drive_until_shutdown(&mut self) -> Promise<(), Error>