Skip to content

Commit

Permalink
Format components debugger and deny_public_fields #21373
Browse files Browse the repository at this point in the history
  • Loading branch information
kingdido999 committed Sep 1, 2018
1 parent 577830d commit e203cde
Show file tree
Hide file tree
Showing 2 changed files with 24 additions and 18 deletions.
36 changes: 20 additions & 16 deletions components/debugger/lib.rs
Expand Up @@ -18,7 +18,7 @@ enum Message {
pub struct Sender(mpsc::Sender<Message>);

struct Connection {
sender: ws::Sender
sender: ws::Sender,
}

impl Handler for Connection {
Expand All @@ -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)
}

Expand Down
6 changes: 4 additions & 2 deletions components/deny_public_fields/lib.rs
Expand Up @@ -14,8 +14,10 @@ decl_derive!([DenyPublicFields] => deny_public_fields_derive);
fn deny_public_fields_derive(s: synstructure::Structure) -> proc_macro::TokenStream {
s.each(|binding| {
if binding.ast().vis != syn::Visibility::Inherited {
panic!("Field `{}` should not be public",
binding.ast().ident.as_ref().unwrap_or(&binding.binding));
panic!(
"Field `{}` should not be public",
binding.ast().ident.as_ref().unwrap_or(&binding.binding)
);
}

"".to_owned()
Expand Down

0 comments on commit e203cde

Please sign in to comment.