Struct Socket 

pub struct Socket<T: IdentityCanonicalizer> { /* private fields */ }

A socket represents an endpoint and other state correspondent uses to connect to peers.

Implementations

impl<T: IdentityCanonicalizer> Socket<T>

pub fn close(&self, error_code: VarInt, reason: &[u8])

Close the socket, shutting down all in-progress operations

pub fn endpoint(&self) -> &Endpoint

Access the internal endpoint object.

Examples found in repository

examples/chat.rs (line 149)

fn read_from_stdin(
    process_id: u32,
    socket: Socket<ProcessIdCanonicalizer>,
    connection_set: SharedConnectionSet,
) {
    use std::io::BufRead;
    let stdin = std::io::stdin();
    let mut lines = stdin.lock().lines();
    show_prompt(process_id);
    while let Some(Ok(line)) = lines.next() {
        let current_peers: Vec<Connection> = {
            let current_peers = connection_set.lock().unwrap();
            // Clone the connections in the set so the mutex can
            // be released early
            current_peers.values().cloned().collect()
        };
        for conn in current_peers {
            let line = line.clone();
            // Use tokio::spawn so messages are sent to peers concurrently
            tokio::spawn(async move {
                let mut stream = conn.open_uni().await.ok()?;
                stream.write_all(line.as_bytes()).await.ok()?;
                stream.finish().await.ok()?;
                Some(())
            });
        }
        show_prompt(process_id);
    }
    // We're done with input, so shutdown the socket
    socket.endpoint().close(0u8.into(), b"");
}

Trait Implementations

impl<T: IdentityCanonicalizer> Clone for Socket<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.