Struct re_sdk_comms::tcp_client::TcpClient

pub struct TcpClient {
    addr: SocketAddr,
    stream_state: TcpStreamState,
    flush_timeout: Option<Duration>,
}

Connect to a rerun server and send log messages.

Blocking connection.

Fields

addr: SocketAddr

stream_state: TcpStreamState

flush_timeout: Option<Duration>

Implementations

impl TcpClient

pub fn new(addr: SocketAddr, flush_timeout: Option<Duration>) -> Self

pub fn connect(&mut self) -> Result<(), ClientError>

Returns false on failure. Does nothing if already connected.

Self::send will call this.

pub fn send(&mut self, packet: &[u8]) -> Result<(), ClientError>

Blocks until it is sent.

pub fn flush(&mut self)

Wait until all logged data have been sent.

pub fn has_timed_out_for_flush(&self) -> bool

Check if the underlying TcpStream is in the TcpStreamState::Pending state and has reached the flush timeout threshold.

Note that this only occurs after a failure to connect or a failure to send.