Function decode_part 

fn decode_part<E, F>(
    part: &mut PendingPart,
    panic_on_audit_failure: bool,
    cap_time: (Timestamp, Subtime),
    name: &str,
    until: &Antichain<Timestamp>,
    map_filter_project: Option<&MfpPlan>,
    datum_vec: &mut DatumVec,
    row_builder: &mut Row,
    work: &mut usize,
    yield_fuel: usize,
    give: F,
) -> bool
where
    E: ExchangeData + Ord + Clone + Debug + From<DataflowError> + From<EvalError>,
    F: FnMut(Result<Cow<'_, Row>, E>, (Timestamp, Subtime), Diff),

Read part, apply the MFP, and hand every record to give, stopping once work reaches yield_fuel. Returns whether the part is exhausted.

Records carry cap_time with its millisecond replaced by the record’s own time, so the caller must emit them at the capability cap_time came from.