water 0.2.8-alpha

A Rust library that provides a thread-safe distributed message sending facility supporting synchronous and asynchronous I/O.
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

use std::sync::Arc;
use std::sync::Mutex;

use net::Net;
use net::NetProtocolAddress;

pub type TCPLISTENER = Arc<Mutex<TCPListener>>;
pub type TCPCONNECTOR = Arc<Mutex<TCPConnector>>;

pub struct TCPListener {
    a: uint,
}
pub struct TCPConnector {
    a: uint,
}

impl Sync for TCPListener { }

impl TCPListener {
    pub fn new(net: &Net, host: String, port: u16) -> TCPLISTENER {
        Arc::new(Mutex::new(TCPListener { a: 0 }))
    }
}

impl TCPConnector {
    pub fn new(net: &Net, host: String, port: u16) -> TCPCONNECTOR {
        Arc::new(Mutex::new(TCPConnector { a: 0 }))
    }
}