Struct mz_timely_util::builder_async::InputHandleQueue

struct InputHandleQueue<T: Timestamp, D: Container, C: InputConnection<T>, P: Pull<Bundle<T, D>> + 'static> {
    queue: Rc<RefCell<VecDeque<Event<T, C::Capability, D>>>>,
    waker: Rc<Cell<Option<Waker>>>,
    connection: C,
    handle: InputHandleCore<T, D, P>,
}

Fields

queue: Rc<RefCell<VecDeque<Event<T, C::Capability, D>>>>

waker: Rc<Cell<Option<Waker>>>

connection: C

handle: InputHandleCore<T, D, P>

Trait Implementations

impl<T, D, C, P> InputQueue<T> for InputHandleQueue<T, D, C, P>

where T: Timestamp, D: Container, C: InputConnection<T> + 'static, P: Pull<Bundle<T, D>> + 'static,

fn accept_input(&mut self)

Accepts all available input into local queues.

fn drain_input(&mut self)

Drains all available input and empties the local queue.

fn notify_progress(&mut self, upper: Antichain<T>)

Registers a frontier notification to be delivered.