Struct UtpListener

pub struct UtpListener { /* private fields */ }

A structure representing a socket server.

Examples

use utp::{UtpListener, UtpSocket};
use std::thread;

fn handle_client(socket: UtpSocket) {
    // ...
}

fn main() {
    // Create a listener
    let addr = "127.0.0.1:8080";
    let listener = UtpListener::bind(addr).expect("Error binding socket");

    for connection in listener.incoming() {
        // Spawn a new handler for each new connection
        if let Ok((socket, _src)) = connection {
            thread::spawn(move || handle_client(socket));
        }
    }
}

Implementations

impl UtpListener

pub fn bind<A: ToSocketAddrs>(addr: A) -> Result<UtpListener>

Creates a new UtpListener bound to a specific address.

The resulting listener is ready for accepting connections.

The address type can be any implementer of the ToSocketAddr trait. See its documentation for concrete examples.

If more than one valid address is specified, only the first will be used.

pub fn accept(&self) -> Result<(UtpSocket, SocketAddr)>

Accepts a new incoming connection from this listener.

This function will block the caller until a new uTP connection is established. When established, the corresponding UtpSocket and the peer’s remote address will be returned.

Notice that the resulting UtpSocket is bound to a different local port than the public listening port (which UtpListener holds). This may confuse the remote peer!

pub fn incoming(&self) -> Incoming<'_>

Returns an iterator over the connections being received by this listener.

The returned iterator will never return None.

pub fn local_addr(&self) -> Result<SocketAddr>

Returns the local socket address of this listener.