Struct diem_secure_net::NetworkServer

pub struct NetworkServer { /* private fields */ }

Implementations

impl NetworkServer

pub fn new(service: &'static str, listen: SocketAddr, timeout_ms: u64) -> Self

pub fn read(&mut self) -> Result<Vec<u8>, Error>

If there isn’t already a downstream client, it accepts. Otherwise it blocks until able to successfully read an entire message

pub fn shutdown(&mut self) -> Result<(), Error>

Shutdown the internal network stream

pub fn write(&mut self, data: &[u8]) -> Result<(), Error>

If there isn’t already a downstream client, it accepts. Otherwise it blocks until it is able to successfully send an entire message.