MCPcopy Index your code
hub / github.com/di-sukharev/opencommit / ReadableStreamDefaultControllerCallPullIfNeeded

Function ReadableStreamDefaultControllerCallPullIfNeeded

out/cli.cjs:13297–13319  ·  view source on GitHub ↗
(controller)

Source from the content-addressed store, hash-verified

13295 return x5 instanceof ReadableStreamDefaultController2;
13296 }
13297 function ReadableStreamDefaultControllerCallPullIfNeeded(controller) {
13298 const shouldPull = ReadableStreamDefaultControllerShouldCallPull(controller);
13299 if (!shouldPull) {
13300 return;
13301 }
13302 if (controller._pulling) {
13303 controller._pullAgain = true;
13304 return;
13305 }
13306 controller._pulling = true;
13307 const pullPromise = controller._pullAlgorithm();
13308 uponPromise(pullPromise, () => {
13309 controller._pulling = false;
13310 if (controller._pullAgain) {
13311 controller._pullAgain = false;
13312 ReadableStreamDefaultControllerCallPullIfNeeded(controller);
13313 }
13314 return null;
13315 }, (e3) => {
13316 ReadableStreamDefaultControllerError(controller, e3);
13317 return null;
13318 });
13319 }
13320 function ReadableStreamDefaultControllerShouldCallPull(controller) {
13321 const stream4 = controller._controlledReadableStream;
13322 if (!ReadableStreamDefaultControllerCanCloseOrEnqueue(controller)) {

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…