(
ctx: Ctx<'js>,
objects: ReadableByteStreamObjects<'js, R>,
)
| 1593 | |
| 1594 | fn pull_algorithm<R: ReadableStreamReader<'js>>( |
| 1595 | ctx: Ctx<'js>, |
| 1596 | objects: ReadableByteStreamObjects<'js, R>, |
| 1597 | ) -> Result<( |
| 1598 | Promise<'js>, |
| 1599 | ReadableStreamClassObjects<'js, OwnedBorrowMut<'js, Self>, R>, |
| 1600 | )> { |
| 1601 | let pull_algorithm = objects |
| 1602 | .controller |
| 1603 | .pull_algorithm |
| 1604 | .clone() |
| 1605 | .expect("pull algorithm used after ReadableStreamDefaultControllerClearAlgorithms"); |
| 1606 | let promise_primordials = objects.stream.promise_primordials.clone(); |
| 1607 | let objects_class = objects.into_inner(); |
| 1608 | |
| 1609 | Ok(( |
| 1610 | pull_algorithm.call( |
| 1611 | ctx, |
| 1612 | &promise_primordials, |
| 1613 | ReadableStreamControllerClass::ReadableStreamByteController( |
| 1614 | objects_class.controller.clone(), |
| 1615 | ), |
| 1616 | )?, |
| 1617 | objects_class, |
| 1618 | )) |
| 1619 | } |
| 1620 | |
| 1621 | fn cancel_algorithm<R: ReadableStreamReader<'js>>( |
| 1622 | ctx: Ctx<'js>, |
| 1623 | objects: ReadableByteStreamObjects<'js, R>, |
nothing calls this directly
no test coverage detected