tcplistener-accept-timeout 0.0.0

TcpListener.accept() with a timeout and a check for a pending connection
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

extern crate tcplistener_accept_timeout;
use tcplistener_accept_timeout::TcpListenerAcceptTimeout;

use std::net::{TcpListener, TcpStream, Ipv4Addr};
use std::time::Duration;
use std::thread;

#[test]
fn expire() {
    let listener = TcpListener::bind((Ipv4Addr::LOCALHOST, 0)).unwrap();
    assert!(!listener.connection_pending(Some(Duration::from_millis(100))));
    assert!(listener.accept_timeout(Some(Duration::from_millis(1000))).is_none());
}

#[test]
fn accepted() {
    let listener = TcpListener::bind((Ipv4Addr::LOCALHOST, 0)).unwrap();
    let addr = listener.local_addr().unwrap();
    thread::spawn(move || {
        thread::sleep(Duration::from_millis(500));
        TcpStream::connect(addr).unwrap();
    });
    assert!(!listener.connection_pending(Some(Duration::from_millis(200))));
    assert!(listener.connection_pending(Some(Duration::from_millis(400))));
    assert!(listener.connection_pending(None));
    assert!(listener.accept_timeout(Some(Duration::from_millis(1000))).unwrap().is_ok());
}