Function finalize_callable_outcome

src/python/py_runtime.rs:93–122

(
    background: &CallableTask,
    out_channel: Option<Channel>,
    outcome: CallableOutcome,
)

}

fn finalize_callable_outcome(
    background: &CallableTask,
    out_channel: Option<Channel>,
    outcome: CallableOutcome,
) {
    match outcome {
        CallableOutcome::Cancelled => {}
        CallableOutcome::Failed(message) => {
            if !background.is_done() {
                background.fail(message);
            }
        }
        CallableOutcome::Ready {
            value,
            delivery_buffer,
        } => {
            if background.is_done() {
                return;
            }
            if let Some(channel) = out_channel {
                match channel.send(delivery_buffer.expect("buffer required for delivery")) {
                    Ok(()) => background.complete(value),
                    Err(err) => background.fail(err.to_string()),
                }
            } else {
                background.complete(value);
            }
        }
    }
}

/// The runtime module exposed to Python.
#[pyclass(name = "_RuntimeModule")]