pub fn wait(&self, ts: u64) -> PFuture<()> {
        let (tx, rx) = PFuture::new();
        if self.closed.load(Ordering::SeqCst) {
            tx.fill(Err(Error::RuntimeShutdown));
            return rx;
        }
        if let Err(err) = self.tx.send((ts, tx)) {
            let (_, tx) = err.into_inner();
            tx.fill(Err(Error::RuntimeShutdown));
        }
        rx
    }
/// Returns a Future that is filled once the given timestamp is no longer in
/// advance of the paired dataflow probe's frontier (i.e. returns/unblocks
/// when `!dataflow.less_than(ts)`).
Returns a Future that is filled once the given timestamp is no longer in
advance of the paired dataflow probe's frontier `).
Returns a Future that is filled once the given timestamp is no longer in advance of the paired dataflow probe ' s frontier ` ) .
pub fn wait(&self, ts: u64) -> PFuture<()> {
        let (tx, rx) = PFuture::new();
        if self.closed.load(Ordering::SeqCst) {
            tx.fill(Err(Error::RuntimeShutdown));
            return rx;
        }
        if let Err(err) = self.tx.send((ts, tx)) {
            let (_, tx) = err.into_inner();
            tx.fill(Err(Error::RuntimeShutdown));
        }
        rx
    }
pub fn wait ( & self , ts : u64 ) -> PFuture < ( ) > { let ( tx , rx ) = PFuture :: new ( ) ; if self . closed . load ( Ordering :: SeqCst ) { tx . fill ( Err ( Error :: RuntimeShutdown ) ) ; return rx ; } if let Err ( err ) = self . tx . send ( ( ts , tx ) ) { let ( _ , tx ) = err . into_inner ( ) ; tx . fill ( Err ( Error :: RuntimeShutdown ) ) ; } rx }
Returns a Future that is filled once the given timestamp is no longer in
advance of the paired dataflow probe's frontier (i.e.
Returns a Future that is filled once the given timestamp is no longer in advance of the paired dataflow probe ' s frontier ( i . e .
&self
ts
u64
&self
ts
u64