Skip to main content

send_batches

headless_lms_credit_registration::use_cases::batch_flow

Function send_batches 

Source 
async fn send_batches<F: RegistryBatchFlow, R: StudyRegistry>(
    ctx: &BatchFlowContext<'_>,
    registry: &mut R,
    batches: &mut Vec<PendingBatch<F::Extra, F::Request>>,
    counts: &mut Counts,
    sent: &mut SentTally,
) -> CreditRegistrationResult<()>
Expand description

Sends batches one after another, splitting the ones refused as malformed, and writes each row’s answer. Stops early on shutdown or on an error, leaving what is still unsent in batches.