(reason)
| 519 | }); |
| 520 | }, |
| 521 | cancel(reason) { |
| 522 | // Reject any currently pending pulls here. |
| 523 | for (const pending of this.pendingPulls) { |
| 524 | pending.reject(reason); |
| 525 | } |
| 526 | this.pendingPulls = []; |
| 527 | }, |
| 528 | // We set the highWaterMark to 0 because we do not want the stream to |
| 529 | // start reading immediately on creation. We want it to wait until read |
| 530 | // is called. |
nothing calls this directly
no test coverage detected
searching dependent graphs…