Searched refs:isDisturbed (Results 1 - 10 of 10) sorted by relevance
| /third_party/node/test/parallel/ |
| H A D | test-stream-readable-didRead.js | 4 const { isDisturbed, isErrored, Readable } = require('stream');
10 assert.strictEqual(isDisturbed(readable), false);
36 assert.strictEqual(isDisturbed(readable), true);
|
| H A D | test-whatwg-readablestream.js | 5 const { isDisturbed, isErrored, isReadable } = require('stream');
1578 isDisturbed(stream, false);
1580 isDisturbed(stream, true);
1594 isDisturbed(stream, false);
1596 isDisturbed(stream, true);
1610 isDisturbed(stream, false);
1612 isDisturbed(stream, true);
|
| /third_party/node/lib/ |
| H A D | stream.js | 57 Stream.isDisturbed = utils.isDisturbed;
|
| /third_party/node/deps/undici/src/lib/core/ |
| H A D | util.js | 332 function isDisturbed (body) {
334 stream.isDisturbed
335 ? stream.isDisturbed(body) || body[kBodyUsed] // TODO (fix): Why is body[kBodyUsed] needed?
489 isDisturbed,
|
| /third_party/node/lib/internal/streams/ |
| H A D | utils.js | 286 function isDisturbed(stream) { function
308 isDisturbed,
|
| /third_party/node/deps/undici/src/lib/api/ |
| H A D | readable.js | 138 return util.isDisturbed(this)
209 return util.isDisturbed(self) || isLocked(self)
|
| /third_party/node/deps/undici/src/lib/handler/ |
| H A D | RedirectHandler.js | 90 this.location = this.history.length >= this.maxRedirections || util.isDisturbed(this.opts.body)
|
| /third_party/node/deps/undici/src/lib/cache/ |
| H A D | cache.js | 5 const { kEnumerableProperty, isDisturbed } = require('../core/util')
360 if (innerResponse.body && (isDisturbed(innerResponse.body.stream) || innerResponse.body.stream.locked)) {
|
| /third_party/node/deps/undici/src/lib/fetch/ |
| H A D | response.js | 243 return !!this[kState].body && util.isDisturbed(this[kState].body.stream)
|
| /third_party/node/deps/undici/ |
| H A D | undici.js | 742 function isDisturbed(body) {
743 return !!(body && (stream.isDisturbed ? stream.isDisturbed(body) || body[kBodyUsed] : body[kBodyUsed] || body.readableDidRead || body._readableState && body._readableState.dataEmitted || isReadableAborted(body)));
745 __name(isDisturbed, "isDisturbed");
865 isDisturbed,
5343 if (util.isDisturbed(object) || object.locked) {
5387 assert(!util.isDisturbed(object), "The body has already been consumed.");
5411 if (util.isDisturbed(stream)) {
5569 return body != null && (body.stream.locked || util.isDisturbed(bod
[all...] |
Completed in 10 milliseconds