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

Method pull_algorithm

modules/llrt_stream_web/src/readable/default_controller.rs:549–574  ·  view source on GitHub ↗
(
        ctx: Ctx<'js>,
        objects: ReadableStreamDefaultControllerObjects<'js, R>,
    )

Source from the content-addressed store, hash-verified

547 }
548
549 fn pull_algorithm<R: ReadableStreamReader<'js>>(
550 ctx: Ctx<'js>,
551 objects: ReadableStreamDefaultControllerObjects<'js, R>,
552 ) -> Result<(
553 Promise<'js>,
554 ReadableStreamClassObjects<'js, OwnedBorrowMut<'js, Self>, R>,
555 )> {
556 let pull_algorithm = objects
557 .controller
558 .pull_algorithm
559 .clone()
560 .expect("pull algorithm used after ReadableStreamDefaultControllerClearAlgorithms");
561 let promise_primordials = objects.stream.promise_primordials.clone();
562 let objects_class = objects.into_inner();
563
564 Ok((
565 pull_algorithm.call(
566 ctx,
567 &promise_primordials,
568 ReadableStreamControllerClass::ReadableStreamDefaultController(
569 objects_class.controller.clone(),
570 ),
571 )?,
572 objects_class,
573 ))
574 }
575
576 fn strategy_size_algorithm<R: ReadableStreamReader<'js>>(
577 ctx: Ctx<'js>,

Callers

nothing calls this directly

Calls 4

cloneMethod · 0.45
into_innerMethod · 0.45
callMethod · 0.45

Tested by

no test coverage detected