Struct dataflow::render::context::PendingWork [−][src]
struct PendingWork<K, V, T: Timestamp, R, C: Cursor<K, V, T, R>> {
capability: Capability<T>,
cursor: C,
batch: C::Storage,
}
Fields
capability: Capability<T>
cursor: C
batch: C::Storage
Implementations
Create a new bundle of pending work, from the capability, cursor, and backing storage.
Perform roughly fuel
work through the cursor, applying logic
and sending results to output
.
Auto Trait Implementations
impl<K, V, T, R, C> !RefUnwindSafe for PendingWork<K, V, T, R, C>
impl<K, V, T, R, C> !Send for PendingWork<K, V, T, R, C>
impl<K, V, T, R, C> !Sync for PendingWork<K, V, T, R, C>
impl<K, V, T, R, C> Unpin for PendingWork<K, V, T, R, C> where
C: Unpin,
T: Unpin,
<C as Cursor<K, V, T, R>>::Storage: Unpin,
impl<K, V, T, R, C> !UnwindSafe for PendingWork<K, V, T, R, C>
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