Struct capnp_rpc::twoparty::VatNetwork
[−]
[src]
pub struct VatNetwork<T> where T: Read + 'static { /* fields omitted */ }A vat networks with two parties, the client and the server.
Methods
impl<T> VatNetwork<T> where T: Read[src]
fn new<U>(input_stream: T,
output_stream: U,
side: Side,
receive_options: ReaderOptions)
-> VatNetwork<T> where U: Write + 'static
output_stream: U,
side: Side,
receive_options: ReaderOptions)
-> VatNetwork<T> where U: Write + 'static
Creates a new two-party vat network that will receive data on input_stream and send data on
output_stream. These streams must be futures-enabled, as discussed here:
https://github.com/tokio-rs/tokio-core/issues/61
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<VatId> for VatNetwork<T> where T: Read[src]
fn connect(&mut self, host_id: VatId) -> Option<Box<Connection<VatId>>>
Returns None if hostId refers to the local vat.
fn accept(&mut self) -> Promise<Box<Connection<VatId>>, Error>
Waits for the next incoming connection and return it.