| /third_party/node/deps/npm/node_modules/duplexify/ |
| D | index.js | 96 var ondrain = function() { function
97 var ondrain = self._ondrain
99 if (ondrain) ondrain()
103 self._writable.removeListener('drain', ondrain)
107 if (this._unwrite) process.nextTick(ondrain) // force a drain on stream reset to avoid livelocks
110 this._writable.on('drain', ondrain)
188 var ondrain = this._ondrain
190 if (ondrain) ondrain(err)
|
| /third_party/node/lib/internal/streams/ |
| D | legacy.js | 27 function ondrain() { function
33 dest.on('drain', ondrain);
72 dest.removeListener('drain', ondrain);
|
| D | readable.js | 673 let ondrain;
681 if (ondrain) {
682 dest.removeListener('drain', ondrain);
697 if (ondrain && state.awaitDrainWriters &&
699 ondrain();
718 if (!ondrain) {
723 ondrain = pipeOnDrain(src, dest);
724 dest.on('drain', ondrain);
|
| /third_party/node/test/parallel/ |
| D | test-tls-fast-writing.js | 59 conn.on('drain', ondrain);
62 function ondrain() { function
|
| D | test-tls-over-http-tunnel.js | 140 socket.ondrain = null;
|
| /third_party/node/deps/npm/node_modules/parallel-transform/ |
| D | index.js | 95 var ondrain = this._ondrain;
97 ondrain();
|
| /third_party/node/deps/npm/node_modules/minizlib/node_modules/minipass/ |
| D | index.js | 316 const p = { dest: dest, opts: opts, ondrain: _ => this[RESUME]() }
319 dest.on('drain', p.ondrain)
392 p.dest.removeListener('drain', p.ondrain)
|
| /third_party/node/deps/npm/node_modules/fs-minipass/node_modules/minipass/ |
| D | index.js | 316 const p = { dest: dest, opts: opts, ondrain: _ => this[RESUME]() }
319 dest.on('drain', p.ondrain)
392 p.dest.removeListener('drain', p.ondrain)
|
| /third_party/node/deps/npm/node_modules/pacote/node_modules/minipass/ |
| D | index.js | 316 const p = { dest: dest, opts: opts, ondrain: _ => this[RESUME]() }
319 dest.on('drain', p.ondrain)
392 p.dest.removeListener('drain', p.ondrain)
|
| /third_party/node/deps/npm/node_modules/tar/node_modules/minipass/ |
| D | index.js | 316 const p = { dest: dest, opts: opts, ondrain: _ => this[RESUME]() }
319 dest.on('drain', p.ondrain)
392 p.dest.removeListener('drain', p.ondrain)
|
| /third_party/node/deps/npm/node_modules/sorted-union-stream/node_modules/readable-stream/lib/ |
| D | _stream_readable.js | 544 var ondrain = pipeOnDrain(src);
545 dest.on('drain', ondrain);
552 dest.removeListener('drain', ondrain);
566 ondrain();
|
| /third_party/node/lib/ |
| D | _http_client.js | 404 function ondrain() { function
531 socket.removeListener('drain', ondrain);
568 socket.removeListener('drain', ondrain);
776 socket.on('drain', ondrain);
|
| /third_party/node/deps/npm/node_modules/are-we-there-yet/node_modules/readable-stream/lib/ |
| D | _stream_readable.js | 584 var ondrain = pipeOnDrain(src);
585 dest.on('drain', ondrain);
593 dest.removeListener('drain', ondrain);
607 if (state.awaitDrain && (!dest._writableState || dest._writableState.needDrain)) ondrain();
|
| /third_party/node/deps/npm/node_modules/parallel-transform/node_modules/readable-stream/lib/ |
| D | _stream_readable.js | 584 var ondrain = pipeOnDrain(src);
585 dest.on('drain', ondrain);
593 dest.removeListener('drain', ondrain);
607 if (state.awaitDrain && (!dest._writableState || dest._writableState.needDrain)) ondrain();
|
| /third_party/node/deps/npm/node_modules/stream-iterate/node_modules/readable-stream/lib/ |
| D | _stream_readable.js | 584 var ondrain = pipeOnDrain(src);
585 dest.on('drain', ondrain);
593 dest.removeListener('drain', ondrain);
607 if (state.awaitDrain && (!dest._writableState || dest._writableState.needDrain)) ondrain();
|
| /third_party/node/deps/npm/node_modules/readable-stream/lib/ |
| D | _stream_readable.js | 653 var ondrain = pipeOnDrain(src);
654 dest.on('drain', ondrain);
662 dest.removeListener('drain', ondrain);
674 if (state.awaitDrain && (!dest._writableState || dest._writableState.needDrain)) ondrain();
|
| /third_party/node/deps/npm/node_modules/concat-stream/node_modules/readable-stream/lib/ |
| D | _stream_readable.js | 584 var ondrain = pipeOnDrain(src);
585 dest.on('drain', ondrain);
593 dest.removeListener('drain', ondrain);
607 if (state.awaitDrain && (!dest._writableState || dest._writableState.needDrain)) ondrain();
|
| /third_party/node/deps/npm/node_modules/through2/node_modules/readable-stream/lib/ |
| D | _stream_readable.js | 584 var ondrain = pipeOnDrain(src);
585 dest.on('drain', ondrain);
593 dest.removeListener('drain', ondrain);
607 if (state.awaitDrain && (!dest._writableState || dest._writableState.needDrain)) ondrain();
|
| /third_party/node/deps/npm/node_modules/duplexify/node_modules/readable-stream/lib/ |
| D | _stream_readable.js | 584 var ondrain = pipeOnDrain(src);
585 dest.on('drain', ondrain);
593 dest.removeListener('drain', ondrain);
607 if (state.awaitDrain && (!dest._writableState || dest._writableState.needDrain)) ondrain();
|
| /third_party/node/deps/npm/node_modules/from2/node_modules/readable-stream/lib/ |
| D | _stream_readable.js | 584 var ondrain = pipeOnDrain(src);
585 dest.on('drain', ondrain);
593 dest.removeListener('drain', ondrain);
607 if (state.awaitDrain && (!dest._writableState || dest._writableState.needDrain)) ondrain();
|
| /third_party/node/deps/npm/node_modules/fs-write-stream-atomic/node_modules/readable-stream/lib/ |
| D | _stream_readable.js | 584 var ondrain = pipeOnDrain(src);
585 dest.on('drain', ondrain);
593 dest.removeListener('drain', ondrain);
607 if (state.awaitDrain && (!dest._writableState || dest._writableState.needDrain)) ondrain();
|
| /third_party/node/deps/npm/node_modules/flush-write-stream/node_modules/readable-stream/lib/ |
| D | _stream_readable.js | 584 var ondrain = pipeOnDrain(src);
585 dest.on('drain', ondrain);
593 dest.removeListener('drain', ondrain);
607 if (state.awaitDrain && (!dest._writableState || dest._writableState.needDrain)) ondrain();
|