Struct dataflow::render::context::PendingWork

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

impl<K: PartialEq, V, T: Timestamp, R, C: Cursor<K, V, T, R>> PendingWork<K, V, T, R, C>

fn new(capability: Capability<T>, cursor: C, batch: C::Storage) -> Self

Create a new bundle of pending work, from the capability, cursor, and backing storage.

fn do_work<I, L>(
    &mut self,
    key: &Option<K>,
    logic: &mut L,
    fuel: &mut usize,
    output: &mut OutputHandle<'_, T, I::Item, Tee<T, I::Item>>
) where
    I: IntoIterator,
    I::Item: Data,
    L: for<'a, 'b> FnMut(RefOrMut<'b, K>, RefOrMut<'b, V>, &'a T, &'a R) -> I + 'static, 

Perform roughly fuel work through the cursor, applying logic and sending results to output.