Trait mz_timely_util::builder_async::InputQueue
source · trait InputQueue<T: Timestamp> {
// Required methods
fn accept_input(&mut self);
fn drain_input(&mut self);
fn notify_progress(&mut self, upper: Antichain<T>);
}
Expand description
A helper trait abstracting over an input handle. It facilitates keeping around type erased handles for each of the operator inputs.
Required Methods§
sourcefn accept_input(&mut self)
fn accept_input(&mut self)
Accepts all available input into local queues.
sourcefn drain_input(&mut self)
fn drain_input(&mut self)
Drains all available input and empties the local queue.
sourcefn notify_progress(&mut self, upper: Antichain<T>)
fn notify_progress(&mut self, upper: Antichain<T>)
Registers a frontier notification to be delivered.