use std::thread::{self};
use std::time::{Duration};

use umio::{ELoopBuilder};

use {MockDispatcher, MockMessage};

#[test]
fn positive_execute_shutdown() {
    let eloop_addr = "127.0.0.1:0".parse().unwrap();
    let mut eloop = ELoopBuilder::new()
        .bind_address(eloop_addr)
        .build().unwrap();

    let (dispatcher, _) = MockDispatcher::new();
    let dispatch_send = eloop.channel();
    
    thread::spawn(move || {
        eloop.run(dispatcher).unwrap();
    });
    thread::sleep(Duration::from_millis(50));
    
    dispatch_send.send(MockMessage::Shutdown).unwrap();
    thread::sleep(Duration::from_millis(50));
    
    assert!(dispatch_send.send(MockMessage::SendNotify).is_err());
}