Function handle 

pub fn handle() -> Handle

Returns current loop handle

This only works if running inside the run() function of the main loop

Panics

This function panics if there is no currently running loop (i.e. this function is not running from the inside of run().

Examples found in repository

examples/multi-threaded.rs (line 24)

fn main() {
    let addr = env::args().nth(1).unwrap_or("127.0.0.1:7777".to_string());
    let addr = addr.parse::<SocketAddr>().expect("parse address");

    let socket = StdListener::bind(addr).expect("bind socket");
    let mut threads = Vec::new();
    for thread_no in 0..10 {
        let lst = socket.try_clone().expect("cloning bind socket");
        threads.push(thread::spawn(move || {
            run(|| {
                TcpListener::from_listener(lst, &addr, &handle())
                .expect("listener created")
                .incoming()
                .for_each(|(_sock, addr)| {
                    println!("Accepted {} in thread {}", addr, thread_no);
                    Ok(())
                })
            })
        }))
    }
    for t in threads {
        t.join().expect("thread never joins").expect("accept never fails");
    }
}