Function mz_storage_controller::persist_handles::read_only_table_worker::handle_commands

source ยท 
async fn handle_commands<T>(
    write_handles: &mut BTreeMap<GlobalId, WriteHandle<SourceData, (), T, Diff>>,
    commands: VecDeque<(Span, PersistTableWriteCmd<T>)>,
) -> ControlFlow<String>
where
    T: Timestamp + Lattice + Codec64 + TimestampManipulation,
Expand description

Handles the given commands.