peermerge 0.0.3

Manage JSON-like documents with multiple writers, without a central authority, using a P2P protocol
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

pub(crate) struct YieldNow(pub(crate) bool);

impl core::future::Future for YieldNow {
    type Output = ();
    fn poll(
        mut self: core::pin::Pin<&mut Self>,
        cx: &mut core::task::Context<'_>,
    ) -> core::task::Poll<()> {
        if self.0 {
            core::task::Poll::Ready(())
        } else {
            self.set(Self(true));
            cx.waker().wake_by_ref();
            core::task::Poll::Pending
        }
    }
}

// The futures::lock::Mutex is significantly slower than tokio/async-std Mutexes
// so use that only for WASM builds.
#[cfg(all(not(target_arch = "wasm32"), feature = "async-std"))]
pub(crate) use async_std::sync::Mutex;
#[cfg(target_arch = "wasm32")]
pub(crate) use futures::lock::Mutex;
#[cfg(all(not(target_arch = "wasm32"), feature = "tokio"))]
pub(crate) use tokio::sync::Mutex;