Struct mz_timely_util::builder_async::AsyncOutputHandle

pub struct AsyncOutputHandle<T: Timestamp, CB: ContainerBuilder, P: Push<Bundle<T, CB::Container>> + 'static> {
    handle: Rc<RefCell<OutputHandleCore<'static, T, CB, P>>>,
    wrapper: Rc<Pin<Box<OutputWrapper<T, CB, P>>>>,
    index: usize,
}

Fields

handle: Rc<RefCell<OutputHandleCore<'static, T, CB, P>>>

wrapper: Rc<Pin<Box<OutputWrapper<T, CB, P>>>>

index: usize

Implementations

impl<T, C, P> AsyncOutputHandle<T, CapacityContainerBuilder<C>, P>

where T: Timestamp, C: Container, P: Push<Bundle<T, C>> + 'static,

pub fn give_container(&self, cap: &Capability<T>, container: &mut C)

impl<T, CB, P> AsyncOutputHandle<T, CB, P>

where T: Timestamp, CB: ContainerBuilder, P: Push<Bundle<T, CB::Container>> + 'static,

fn new(wrapper: OutputWrapper<T, CB, P>, index: usize) -> Self

fn cease(&self)

impl<T, C, P> AsyncOutputHandle<T, CapacityContainerBuilder<C>, P>

where T: Timestamp, C: Container, P: Push<Bundle<T, C>> + 'static,

pub fn give<D>(&self, cap: &Capability<T>, data: D)

where CapacityContainerBuilder<C>: PushInto<D>,

impl<T, D, P> AsyncOutputHandle<T, AccountedStackBuilder<CapacityContainerBuilder<StackWrapper<D>>>, P>

where D: Data + Columnation, T: Timestamp, P: Push<Bundle<T, StackWrapper<D>>>,

pub const MAX_OUTSTANDING_BYTES: usize = 134_217_728usize

pub async fn give_fueled<D2>(&self, cap: &Capability<T>, data: D2)

where StackWrapper<D>: PushInto<D2>,

Provides one record at the time specified by the capability. This method will automatically yield back to timely after Self::MAX_OUTSTANDING_BYTES have been produced.

Trait Implementations

impl<T: Timestamp, CB: ContainerBuilder, P: Push<Bundle<T, CB::Container>> + 'static> Clone for AsyncOutputHandle<T, CB, P>

fn clone(&self) -> Self

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Timestamp, CB: ContainerBuilder> OutputIndex for AsyncOutputHandle<T, CB, Tee<T, CB::Container>>

fn index(&self) -> usize

The output index of this handle.