lapin 1.0.0-alpha4

AMQP client library
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

use crate::Result;
use mio::Waker as MioWaker;
use parking_lot::RwLock;
use std::{fmt, sync::Arc};

#[derive(Clone, Default)]
pub(crate) struct Waker {
    inner: Arc<RwLock<Option<MioWaker>>>,
}

impl Waker {
    pub(crate) fn wake(&self) -> Result<()> {
        if let Some(waker) = self.inner.read().as_ref() {
            waker.wake()?;
        }
        Ok(())
    }

    pub(crate) fn set_waker(&self, waker: MioWaker) {
        *self.inner.write() = Some(waker);
    }
}

impl fmt::Debug for Waker {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        f.debug_struct("Waker").finish()
    }
}