(
ctx: Ctx<'js>,
stream_class: &TransformStreamClass<'js>,
)
| 308 | ctx.clone(), |
| 309 | cancel_promise, |
| 310 | move |ctx, result| { |
| 311 | cc.borrow_mut().clear_algorithms(); |
| 312 | match result { |
| 313 | Ok(_) => Ok(Value::new_undefined(ctx)), |
| 314 | Err(r) => Err(ctx.throw(r)), |
| 315 | } |
| 316 | }, |
| 317 | ) |
| 318 | } |
| 319 | |
| 320 | // --- Source algorithms --- |
| 321 | |
| 322 | pub(crate) fn source_pull_algorithm<'js>( |
| 323 | ctx: Ctx<'js>, |
| 324 | stream_class: &TransformStreamClass<'js>, |
| 325 | ) -> Result<Promise<'js>> { |
| 326 | controller::transform_stream_set_backpressure(&ctx, stream_class, false) |
| 327 | } |
| 328 | |
| 329 | pub(crate) fn source_cancel_algorithm<'js>( |
no test coverage detected