packages/mesh/lib/streams/std/readable-stream.js
function ReadableStreamDefaultControllerClose(controller) {
  const stream = controller._controlledReadableStream;

  assert(controller._closeRequested === false);
  assert(stream._state === 'readable');

  controller._closeRequested = true;

  if (controller._queue.length === 0) {
    ReadableStreamClose(stream);
  }
}
function ReadableStreamDefaultControllerClose(controller) {
  const stream = controller._controlledReadableStream;

  assert(controller._closeRequested === false);
  assert(stream._state === 'readable');

  controller._closeRequested = true;

  if (controller._queue.length === 0) {
    ReadableStreamClose(stream);
  }
}
function ReadableStreamDefaultControllerClose ( controller ) { const stream = controller . _controlledReadableStream ; assert ( controller . _closeRequested === false ) ; assert ( stream . _state === 'readable' ) ; controller . _closeRequested = true ; if ( controller . _queue . length === 0 ) { ReadableStreamClose ( stream ) ; } }
A client of ReadableStreamDefaultController may use these functions directly to bypass state check.
A client of ReadableStreamDefaultController may use these functions directly to bypass state check .