rustun 0.1.4

A library for implementing STUN server and client asynchronously
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

use std::net::SocketAddr;
use fibers::Spawn;

use HandleMessage;
use transport::TcpServerTransport;
use server::BaseServer;
use server::futures::BaseServerLoop;

/// TCP STUN server.
#[derive(Debug)]
pub struct TcpServer {
    bind_addr: SocketAddr,
}
impl TcpServer {
    /// Makes a new `TcpServer` instance which will bind to `bind_addr`.
    pub fn new(bind_addr: SocketAddr) -> Self {
        TcpServer { bind_addr: bind_addr }
    }

    /// Starts the TCP server with `handler`.
    pub fn start<S, H>(&self, spawner: S, handler: H) -> TcpServerLoop<H>
        where S: Spawn + Clone + Send + 'static,
              H: HandleMessage
    {
        let transport = TcpServerTransport::new(spawner.clone(), self.bind_addr);
        BaseServer::start(spawner, transport, handler)
    }
}

/// `Future` that represent the loop of a TCP server for handling transactions issued by clients.
pub type TcpServerLoop<H> = BaseServerLoop<TcpServerTransport, H>;