sctpx/
lib.rs

1#[cfg(feature = "client")]
2pub mod client;
3#[cfg(feature = "server")]
4pub mod server;
5
6#[cfg(feature = "client")]
7#[cfg(feature = "server")]
8#[cfg(test)]
9mod test {
10    use super::{client, server};
11    use ruc::*;
12    use std::{sync::Arc, thread, time::Duration};
13
14    #[test]
15    fn itworks() {
16        const ADDR: &str = "127.0.0.1:9999";
17
18        thread::spawn(|| {
19            let cb = |recvd: &[u8],
20                      hdr: Arc<server::Hdr>,
21                      peer: server::PeerAddr|
22             -> Result<()> {
23                assert_eq!(b"ABC", recvd);
24                hdr.sendto(b"DEF", &peer).map(|n| assert_eq!(n, 3)).c(d!())
25            };
26            pnk!(server::start_server(ADDR, None, cb, false));
27        });
28
29        // wait server to start
30        thread::sleep(Duration::from_secs(1));
31
32        let cli = pnk!(client::Hdr::new());
33        assert_eq!(3, pnk!(cli.sendto_straddr(b"ABC", ADDR)));
34
35        let buf = &mut [0; 8];
36        let res = pnk!(cli.recvfrom(buf));
37        assert_eq!(b"DEF", &buf[0..res.0]);
38        assert_eq!(res.0, 3);
39        assert_eq!(pnk!(res.1).to_string().as_str(), ADDR);
40    }
41}
sctpx/lib.rs

sctpx/
lib.rs
