Sha256: 2cfce0930b3ba32309417c504b93a7baaf9be6852ce3c6942789322712eb23b1
Contents?: true
Size: 505 Bytes
Versions: 8
Compression:
Stored size: 505 Bytes
Contents
use std::task::Waker; pub(crate) struct Defer { deferred: Vec<Waker>, } impl Defer { pub(crate) fn new() -> Defer { Defer { deferred: Default::default(), } } pub(crate) fn defer(&mut self, waker: Waker) { self.deferred.push(waker); } pub(crate) fn is_empty(&self) -> bool { self.deferred.is_empty() } pub(crate) fn wake(&mut self) { for waker in self.deferred.drain(..) { waker.wake(); } } }
Version data entries
8 entries across 8 versions & 1 rubygems