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

Function WritableStreamUpdateBackpressure

out/cli.cjs:12429–12439  ·  view source on GitHub ↗
(stream4, backpressure)

Source from the content-addressed store, hash-verified

12427 }
12428 }
12429 function WritableStreamUpdateBackpressure(stream4, backpressure) {
12430 const writer = stream4._writer;
12431 if (writer !== void 0 && backpressure !== stream4._backpressure) {
12432 if (backpressure) {
12433 defaultWriterReadyPromiseReset(writer);
12434 } else {
12435 defaultWriterReadyPromiseResolve(writer);
12436 }
12437 }
12438 stream4._backpressure = backpressure;
12439 }
12440 class WritableStreamDefaultWriter2 {
12441 constructor(stream4) {
12442 assertRequiredArgument(stream4, 1, "WritableStreamDefaultWriter");

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…