Struct mz_timely_util::builder_async::AsyncInputHandle

pub struct AsyncInputHandle<T: Timestamp, D: Container, C: InputConnection<T>> {
    queue: Rc<RefCell<VecDeque<Event<T, C::Capability, D>>>>,
    waker: Rc<Cell<Option<Waker>>>,
    done: bool,
}

Async handle to an operator’s input stream

Fields

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

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

done: bool

Whether this handle has finished producing data

Implementations

impl<T: Timestamp, D: Container, C: InputConnection<T>> AsyncInputHandle<T, D, C>

pub fn next_sync(&mut self) -> Option<Event<T, C::Capability, D>>

pub async fn ready(&self)

Waits for the handle to have data. After this function returns it is guaranteed that at least one call to next_sync will be Some(_).

fn poll_ready(&self, cx: &Context<'_>) -> Poll<()>

Trait Implementations

impl<T: Timestamp, D: Container, C: InputConnection<T>> Stream for AsyncInputHandle<T, D, C>

type Item = Event<T, <C as InputConnection<T>>::Capability, D>

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.