Struct Operator

pub struct Operator { /* private fields */ }

Implementations

impl Operator

pub fn new(conn: TcpStream) -> Self

pub fn ping_write_then_read(&mut self) -> Result<()>

pub fn ping_read_then_write(&mut self) -> Result<()>

pub fn request_downstream(&mut self, duration: Duration) -> Result<()>

pub fn request_upstream(&mut self, duration: Duration) -> Result<()>

pub fn write_loop(&mut self, timeout: Duration) -> Result<u64>

pub fn read_loop(&mut self) -> Result<u64>

pub fn send_buffer(&mut self, buff: &[u8]) -> Result<()>

pub fn receive_buffer(&mut self, buff: &mut [u8]) -> Result<()>

pub fn write(&mut self, cmd: Command) -> Result<()>

pub fn read(&mut self) -> Result<Command>

pub fn write_duration(&mut self, duration: Duration) -> Result<()>

pub fn read_duration(&mut self) -> Result<Duration>

pub fn expect(&mut self, expect: Command) -> Result<()>

pub fn write_decline( &mut self, reason: DeclineReason, shutdown: bool, ) -> Result<()>

pub fn read_decline_reason(&mut self) -> Result<DeclineReason>