Method give

src/timely-util/src/builder_async.rs:241–260

Provides data at the time specified by the capability. Flushes automatically when the capability time changes.

(&mut self, cap: &Capability<T>, data: D)

    /// Provides data at the time specified by the capability. Flushes automatically when the
    /// capability time changes.
    fn give<D>(&mut self, cap: &Capability<T>, data: D)
    where
        CB: PushInto<D>,
    {
        if let Some(capability) = &self.capability
            && cap.time() != capability.time()
        {
            self.flush();
            self.capability = None;
        }
        if self.capability.is_none() {
            self.capability = Some(cap.clone());
        }

        self.builder.push_into(data);
        while let Some(container) = self.builder.extract() {
            self.output
                .give(self.capability.as_ref().expect("must exist"), container);
        }
    }
}

pub struct AsyncOutputHandle<T: Timestamp, CB: ContainerBuilder> {