MCPcopy Create free account
hub / github.com/awslabs/llrt / pull_algorithm

Method pull_algorithm

modules/llrt_stream_web/src/readable/byte_controller.rs:1595–1620  ·  view source on GitHub ↗
(
        ctx: Ctx<'js>,
        objects: ReadableByteStreamObjects<'js, R>,
    )

Source from the content-addressed store, hash-verified

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>,

Callers

nothing calls this directly

Calls 3

cloneMethod · 0.45
into_innerMethod · 0.45
callMethod · 0.45

Tested by

no test coverage detected