Method load

lambda-runtime-api-client/src/body/watch.rs:62–65

(&mut self, cx: &mut task::Context<'_>)

impl Receiver {
    pub(crate) fn load(&mut self, cx: &mut task::Context<'_>) -> Value {
        self.shared.waker.register(cx.waker());
        self.shared.value.load(Ordering::SeqCst)
    }

    #[allow(unused)]
    pub(crate) fn peek(&self) -> Value {