Struct ClientSocket

pub struct ClientSocket { /* private fields */ }

Client used to communicate with GameServer. Must be singleton in your app.

Implementations

impl ClientSocket

pub fn new( port: u16, server_address: impl ToSocketAddrs, ) -> Result<ClientSocket, Exception>

Create new client and listen on port to recv packets from server_address and send its to them.

Examples found in repository

examples/ping_pong_client.rs (line 6)

fn main() {
    let mut client = victorem::ClientSocket::new(11111, "127.0.0.1:22222").unwrap();
    let mut id: u32 = 0;
    let mut timer = Instant::now();
    let period = Duration::from_millis(100);
    loop {
        if timer.elapsed() > period {
            timer = Instant::now();
            id += 1;
            let _ = client.send(format!("Ping {}", id).into_bytes());
        }
        let _ = client
            .recv()
            .map(|v| String::from_utf8(v).unwrap_or(String::new()))
            .map(|s| println!("From Server: {}", s));
    }
}

pub fn send(&mut self, command: Vec<u8>) -> Result<usize, Exception>

Send data to server Don’t block current thread may wait up to 30 milliseconds if you send commands too often Commands ordered and with some guarantees.

Examples found in repository

examples/ping_pong_client.rs (line 14)

fn main() {
    let mut client = victorem::ClientSocket::new(11111, "127.0.0.1:22222").unwrap();
    let mut id: u32 = 0;
    let mut timer = Instant::now();
    let period = Duration::from_millis(100);
    loop {
        if timer.elapsed() > period {
            timer = Instant::now();
            id += 1;
            let _ = client.send(format!("Ping {}", id).into_bytes());
        }
        let _ = client
            .recv()
            .map(|v| String::from_utf8(v).unwrap_or(String::new()))
            .map(|s| println!("From Server: {}", s));
    }
}

pub fn recv(&mut self) -> Result<Vec<u8>, Exception>

Reads data from server. Don’t block current thread. Return Exception with std::io::ErrorKind::WouldBlock if there is no data available. Data ordered and without some guarantees.

Examples found in repository

examples/ping_pong_client.rs (line 17)

fn main() {
    let mut client = victorem::ClientSocket::new(11111, "127.0.0.1:22222").unwrap();
    let mut id: u32 = 0;
    let mut timer = Instant::now();
    let period = Duration::from_millis(100);
    loop {
        if timer.elapsed() > period {
            timer = Instant::now();
            id += 1;
            let _ = client.send(format!("Ping {}", id).into_bytes());
        }
        let _ = client
            .recv()
            .map(|v| String::from_utf8(v).unwrap_or(String::new()))
            .map(|s| println!("From Server: {}", s));
    }
}