diff options
Diffstat (limited to 'components/debugger/lib.rs')
| -rw-r--r-- | components/debugger/lib.rs | 36 |
1 files changed, 20 insertions, 16 deletions
diff --git a/components/debugger/lib.rs b/components/debugger/lib.rs index ec0e5ba0e80..6190ebec89b 100644 --- a/components/debugger/lib.rs +++ b/components/debugger/lib.rs @@ -18,7 +18,7 @@ enum Message { pub struct Sender(mpsc::Sender<Message>); struct Connection { - sender: ws::Sender + sender: ws::Sender, } impl Handler for Connection { @@ -39,23 +39,27 @@ impl Handler for Connection { pub fn start_server(port: u16) -> Sender { debug!("Starting server."); let (sender, receiver) = channel(); - thread::Builder::new().name("debugger".to_owned()).spawn(move || { - let socket = Builder::new().build(|sender: ws::Sender| { - Connection { sender: sender } - }).unwrap(); - let sender = socket.broadcaster(); - thread::Builder::new().name("debugger-websocket".to_owned()).spawn(move || { - socket.listen(("127.0.0.1", port)).unwrap(); - }).expect("Thread spawning failed"); - while let Ok(message) = receiver.recv() { - match message { - Message::ShutdownServer => { - break; + thread::Builder::new() + .name("debugger".to_owned()) + .spawn(move || { + let socket = Builder::new() + .build(|sender: ws::Sender| Connection { sender: sender }) + .unwrap(); + let sender = socket.broadcaster(); + thread::Builder::new() + .name("debugger-websocket".to_owned()) + .spawn(move || { + socket.listen(("127.0.0.1", port)).unwrap(); + }).expect("Thread spawning failed"); + while let Ok(message) = receiver.recv() { + match message { + Message::ShutdownServer => { + break; + }, } } - } - sender.shutdown().unwrap(); - }).expect("Thread spawning failed"); + sender.shutdown().unwrap(); + }).expect("Thread spawning failed"); Sender(sender) } |