(
ctx: Ctx<'js>,
objects: ReadableStreamDefaultControllerObjects<'js, R>,
reason: Value<'js>,
)
| 592 | } |
| 593 | |
| 594 | pub(super) fn cancel_algorithm<R: ReadableStreamReader<'js>>( |
| 595 | ctx: Ctx<'js>, |
| 596 | objects: ReadableStreamDefaultControllerObjects<'js, R>, |
| 597 | reason: Value<'js>, |
| 598 | ) -> Result<( |
| 599 | Promise<'js>, |
| 600 | ReadableStreamClassObjects<'js, OwnedBorrowMut<'js, Self>, R>, |
| 601 | )> { |
| 602 | let cancel_algorithm = |
| 603 | objects.controller.cancel_algorithm.clone().expect( |
| 604 | "cancel algorithm used after ReadableStreamDefaultControllerClearAlgorithms", |
| 605 | ); |
| 606 | let promise_primordials = objects.stream.promise_primordials.clone(); |
| 607 | let objects_class = objects.into_inner(); |
| 608 | |
| 609 | Ok(( |
| 610 | cancel_algorithm.call(ctx, &promise_primordials, reason)?, |
| 611 | objects_class, |
| 612 | )) |
| 613 | } |
| 614 | } |
| 615 | |
| 616 | #[methods(rename_all = "camelCase")] |
nothing calls this directly
no test coverage detected