pub trait RemapHandleReader {
    type FromTime: Timestamp;
    type IntoTime: Timestamp;

    fn next<'life0, 'async_trait>(
        &'life0 mut self
    ) -> Pin<Box<dyn Future<Output = Option<(Vec<(Self::FromTime, Self::IntoTime, Diff)>, Antichain<Self::IntoTime>)>> + 'async_trait>>
        Self: 'async_trait,
        'life0: 'async_trait
; }
Expand description

A handle that can produce the data expressing the translation of FromTime to IntoTime.

This trait is a subtrait of RemapHandle so it can be shared between the primary reclocking implementation and remap collection migrations.

Required Associated Types§

Required Methods§

Produces the next batch of data contained in the remap collection and the upper frontier of that batch. The return batch should contain all the updates that happened at times not beyond ther returned upper.