Struct persist::operators::stream::CompactionFuture [−][src]
struct CompactionFuture<F: Future<Output = Result<SeqNo, Error>>> {
frontier: Antichain<u64>,
fut: F,
}
Fields
frontier: Antichain<u64>
fut: F
Auto Trait Implementations
impl<F> RefUnwindSafe for CompactionFuture<F> where
F: RefUnwindSafe,
impl<F> Send for CompactionFuture<F> where
F: Send,
impl<F> Sync for CompactionFuture<F> where
F: Sync,
impl<F> Unpin for CompactionFuture<F> where
F: Unpin,
impl<F> UnwindSafe for CompactionFuture<F> where
F: UnwindSafe,
Blanket Implementations
Mutably borrows from an owned value. Read more
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more