Function source_cancel_algorithm

modules/llrt_stream_web/src/transform/stream.rs:328–350

(
    ctx: Ctx<'js>,
    stream_class: &TransformStreamClass<'js>,
    controller_class: &TransformStreamDefaultControllerClass<'js>,
    reason: Value<'js>,
)

    controller::transform_stream_set_backpressure(&ctx, stream_class, false)
}

pub(crate) fn source_cancel_algorithm<'js>(
    ctx: Ctx<'js>,
    stream_class: &TransformStreamClass<'js>,
    controller_class: &TransformStreamDefaultControllerClass<'js>,
    reason: Value<'js>,
) -> Result<Promise<'js>> {
    let cancel_promise = controller::perform_cancel(ctx.clone(), controller_class, reason.clone())?;

    let sc = stream_class.clone();
    let cc = controller_class.clone();
    crate::utils::promise::upon_promise::<Value<'js>, _>(
        ctx.clone(),
        cancel_promise,
        move |ctx, result| {
            cc.borrow_mut().clear_algorithms();
            controller::transform_stream_error_writable_and_unblock_write(&sc, reason)?;
            match result {
                Ok(_) => Ok(Value::new_undefined(ctx)),
                Err(r) => Err(ctx.throw(r)),
            }
        },
    )
}