Skip to content

Instantly share code, notes, and snippets.

@bradfier
bradfier / main.rs
Created September 19, 2016 13:38 — forked from tilpner/main.rs
extern crate libc;
use std::{thread, process};
use std::time::Duration;
fn sigint_handler(sig: libc::c_int) {
if sig != libc::SIGINT {
println!("Oops, not for me. Ignoring {}.", sig);
return;
}
public class Minimal {
public void func(String args) {
int i = 42;
i >>>= 1;
return i;
}
}
// -----------------------------------
public class Minimal {
public void func(String args) {
Red Science:
0eNqdmttu6zYQRf9Fz1YhXhX7Vw4OCkVhE6K6QZLbBkH+vcqxnTQNHc/ik2Gb3kOtGc6F8Etx3x3DNMdhLQ4vRWzHYSkOP16KJT4OTff22fo8heJQxDX0xa4Ymv7t3dLGMLShnJr2z1IVr7siDg/hn+KgXn/uijCscY3hpPTrzfPvw7G/D/O24F2jWZbQ33dxeCz7pn2KQyj1ZmEal+3H4/BmexMs613xvL3ozcYc2jglzX8xo9/N/NEsa7nOzbBM47yW96FbE1bsyYrZrDzEzc7pO5tQNlDZJJV9Qtl+Vj5uROfHedxer2nrtPbu4rTxuE7HNcXHQTdUWV7wn58oDkuY1+2LL/LpB9EJyZpCMjcYxeEKorvPlpapi2ty8+fY0b+52z7es+hx4uBR1btyHx7isS9Dt62fY1tOYxe+SvuLdEpMsW3W4tOjPg5mN24h99RsDnz4JjLKMwIlQGCk4XYR1bfjTVnI9XLgdRKsy8seSkDW56U8iXSdJ60F0ndin+nkfpM++zhlS990Xdk1/XQ16SQdpelxet9dSgweJyN+Uq2zlAWO0bDOyaNJ26wcmHaTk4aPk+/P0xLjk1QFJUbXWXlW386FWnyu6u8Cdy9V8d+omCqv51Os2TAKpv/q9vkymeVKUK2MESWpcy5Ng7VZ1USQV0xenaoE7XNemZIo0yqlUzSSyrRISSJrn9WBwzNhK+nOLw5MidCZ7aQFZwVLj5oYtTVw//4r6jiPQ/kYmrn8+ymELvkANqdiCgLb0sN4ykGCbtz6LGVB+2DzWkZBZbN3WcrJOcfupTPeOcGJZjxXZSUiwZDnYCNZKrGyztqzIBKcgZ10dd1fzsIckXx+/XZHtcbufEH1/ye7+xhmz7bacWjnsIZfp/7Kcs2WK7S8QquZNtu4lErNINYMYs0g1ghijSDWCGKNIHoG0TOInkH0CKJHED2C6BFExyA6BtExiA5BdAiiQxAdgmgZRMsgWgbRIogWQbQIokUQDYNoGETDI
diff --git a/src/async.rs b/src/async.rs
index a5f17be7..ce0971c6 100644
--- a/src/async.rs
+++ b/src/async.rs
@@ -24,7 +24,7 @@ use message::Msg;
/// drive a `Readiness` stream for use with Tokio.
pub(crate) struct AsyncQueue {
queue: Queue,
- listeners: Arc<Mutex<Vec<mio::SetReadiness>>>,
+ listeners: Box<Mutex<Vec<mio::SetReadiness>>>,