use std::{
io::{self, Write},
os::unix::net::UnixStream,
sync::{Arc, Mutex},
};
#[derive(Clone, Debug)]
pub(crate) struct Waker {
inner: Arc<Mutex<UnixStream>>,
}
impl Waker {
pub(crate) fn new(writer: UnixStream) -> Self {
Self {
inner: Arc::new(Mutex::new(writer)),
}
}
pub(crate) fn wake(&self) -> io::Result<()> {
self.inner.lock().unwrap().write_all(&[0])?;
Ok(())
}
}