Sha256: 2e53479e68f48bf39c8cce92f0d12422bf4c68d931e741aae8daed854cd3f6ac
Contents?: true
Size: 487 Bytes
Versions: 31
Compression:
Stored size: 487 Bytes
Contents
use super::{Driver, Handle, TOKEN_SIGNAL};
use std::io;
impl Handle {
pub(crate) fn register_signal_receiver(
&self,
receiver: &mut mio::net::UnixStream,
) -> io::Result<()> {
self.registry
.register(receiver, TOKEN_SIGNAL, mio::Interest::READABLE)?;
Ok(())
}
}
impl Driver {
pub(crate) fn consume_signal_ready(&mut self) -> bool {
let ret = self.signal_ready;
self.signal_ready = false;
ret
}
}
Version data entries
31 entries across 31 versions & 1 rubygems