(
ctx: Ctx<'js>,
objects: ReadableByteStreamObjects<'js, R>,
reason: Value<'js>,
)
| 1620 | |
| 1621 | fn cancel_algorithm<R: ReadableStreamReader<'js>>( |
| 1622 | ctx: Ctx<'js>, |
| 1623 | objects: ReadableByteStreamObjects<'js, R>, |
| 1624 | reason: Value<'js>, |
| 1625 | ) -> Result<( |
| 1626 | Promise<'js>, |
| 1627 | ReadableStreamClassObjects<'js, OwnedBorrowMut<'js, Self>, R>, |
| 1628 | )> { |
| 1629 | let cancel_algorithm = |
| 1630 | objects.controller.cancel_algorithm.clone().expect( |
| 1631 | "cancel algorithm used after ReadableStreamDefaultControllerClearAlgorithms", |
| 1632 | ); |
| 1633 | let promise_primordials = objects.stream.promise_primordials.clone(); |
| 1634 | let objects_class = objects.into_inner(); |
| 1635 | |
| 1636 | Ok(( |
| 1637 | cancel_algorithm.call(ctx, &promise_primordials, reason)?, |
| 1638 | objects_class, |
| 1639 | )) |
| 1640 | } |
| 1641 | } |
| 1642 | |
| 1643 | #[methods(rename_all = "camelCase")] |
| 1644 | impl<'js> ReadableByteStreamController<'js> { |
nothing calls this directly
no test coverage detected