Searched refs:_writableState (Results 1 – 25 of 98) sorted by relevance
1234
| /third_party/node/deps/npm/node_modules/readable-stream/lib/internal/streams/ |
| D | destroy.js | 7 var writableDestroyed = this._writableState && this._writableState.destroyed;
13 if (!this._writableState) {
15 } else if (!this._writableState.errorEmitted) {
16 this._writableState.errorEmitted = true;
31 if (this._writableState) {
32 this._writableState.destroyed = true;
37 if (!_this._writableState) {
39 } else if (!_this._writableState.errorEmitted) {
40 _this._writableState.errorEmitted = true;
62 if (self._writableState && !self._writableState.emitClose) return;
[all …]
|
| /third_party/node/deps/npm/node_modules/flush-write-stream/node_modules/readable-stream/lib/internal/streams/ |
| D | destroy.js | 13 var writableDestroyed = this._writableState && this._writableState.destroyed;
18 } else if (err && (!this._writableState || !this._writableState.errorEmitted)) {
32 if (this._writableState) {
33 this._writableState.destroyed = true;
39 if (_this._writableState) {
40 _this._writableState.errorEmitted = true;
58 if (this._writableState) {
59 this._writableState.destroyed = false;
60 this._writableState.ended = false;
61 this._writableState.ending = false;
[all …]
|
| /third_party/node/deps/npm/node_modules/stream-iterate/node_modules/readable-stream/lib/internal/streams/ |
| D | destroy.js | 13 var writableDestroyed = this._writableState && this._writableState.destroyed;
18 } else if (err && (!this._writableState || !this._writableState.errorEmitted)) {
32 if (this._writableState) {
33 this._writableState.destroyed = true;
39 if (_this._writableState) {
40 _this._writableState.errorEmitted = true;
58 if (this._writableState) {
59 this._writableState.destroyed = false;
60 this._writableState.ended = false;
61 this._writableState.ending = false;
[all …]
|
| /third_party/node/deps/npm/node_modules/concat-stream/node_modules/readable-stream/lib/internal/streams/ |
| D | destroy.js | 13 var writableDestroyed = this._writableState && this._writableState.destroyed;
18 } else if (err && (!this._writableState || !this._writableState.errorEmitted)) {
32 if (this._writableState) {
33 this._writableState.destroyed = true;
39 if (_this._writableState) {
40 _this._writableState.errorEmitted = true;
58 if (this._writableState) {
59 this._writableState.destroyed = false;
60 this._writableState.ended = false;
61 this._writableState.ending = false;
[all …]
|
| /third_party/node/deps/npm/node_modules/fs-write-stream-atomic/node_modules/readable-stream/lib/internal/streams/ |
| D | destroy.js | 13 var writableDestroyed = this._writableState && this._writableState.destroyed;
18 } else if (err && (!this._writableState || !this._writableState.errorEmitted)) {
32 if (this._writableState) {
33 this._writableState.destroyed = true;
39 if (_this._writableState) {
40 _this._writableState.errorEmitted = true;
58 if (this._writableState) {
59 this._writableState.destroyed = false;
60 this._writableState.ended = false;
61 this._writableState.ending = false;
[all …]
|
| /third_party/node/deps/npm/node_modules/parallel-transform/node_modules/readable-stream/lib/internal/streams/ |
| D | destroy.js | 13 var writableDestroyed = this._writableState && this._writableState.destroyed;
18 } else if (err && (!this._writableState || !this._writableState.errorEmitted)) {
32 if (this._writableState) {
33 this._writableState.destroyed = true;
39 if (_this._writableState) {
40 _this._writableState.errorEmitted = true;
58 if (this._writableState) {
59 this._writableState.destroyed = false;
60 this._writableState.ended = false;
61 this._writableState.ending = false;
[all …]
|
| /third_party/node/deps/npm/node_modules/duplexify/node_modules/readable-stream/lib/internal/streams/ |
| D | destroy.js | 13 var writableDestroyed = this._writableState && this._writableState.destroyed;
18 } else if (err && (!this._writableState || !this._writableState.errorEmitted)) {
32 if (this._writableState) {
33 this._writableState.destroyed = true;
39 if (_this._writableState) {
40 _this._writableState.errorEmitted = true;
58 if (this._writableState) {
59 this._writableState.destroyed = false;
60 this._writableState.ended = false;
61 this._writableState.ending = false;
[all …]
|
| /third_party/node/deps/npm/node_modules/are-we-there-yet/node_modules/readable-stream/lib/internal/streams/ |
| D | destroy.js | 13 var writableDestroyed = this._writableState && this._writableState.destroyed;
18 } else if (err && (!this._writableState || !this._writableState.errorEmitted)) {
32 if (this._writableState) {
33 this._writableState.destroyed = true;
39 if (_this._writableState) {
40 _this._writableState.errorEmitted = true;
58 if (this._writableState) {
59 this._writableState.destroyed = false;
60 this._writableState.ended = false;
61 this._writableState.ending = false;
[all …]
|
| /third_party/node/deps/npm/node_modules/from2/node_modules/readable-stream/lib/internal/streams/ |
| D | destroy.js | 13 var writableDestroyed = this._writableState && this._writableState.destroyed;
18 } else if (err && (!this._writableState || !this._writableState.errorEmitted)) {
32 if (this._writableState) {
33 this._writableState.destroyed = true;
39 if (_this._writableState) {
40 _this._writableState.errorEmitted = true;
58 if (this._writableState) {
59 this._writableState.destroyed = false;
60 this._writableState.ended = false;
61 this._writableState.ending = false;
[all …]
|
| /third_party/node/deps/npm/node_modules/through2/node_modules/readable-stream/lib/internal/streams/ |
| D | destroy.js | 13 var writableDestroyed = this._writableState && this._writableState.destroyed;
18 } else if (err && (!this._writableState || !this._writableState.errorEmitted)) {
32 if (this._writableState) {
33 this._writableState.destroyed = true;
39 if (_this._writableState) {
40 _this._writableState.errorEmitted = true;
58 if (this._writableState) {
59 this._writableState.destroyed = false;
60 this._writableState.ended = false;
61 this._writableState.ending = false;
[all …]
|
| /third_party/node/test/parallel/ |
| D | test-stream-writableState-uncorked-bufferedRequestCount.js | 20 assert.strictEqual(writable._writableState.corked, 1);
21 assert.strictEqual(writable._writableState.bufferedRequestCount, 0);
25 assert.strictEqual(writable._writableState.corked, 2);
29 assert.strictEqual(writable._writableState.bufferedRequestCount, 1);
33 assert.strictEqual(writable._writableState.corked, 1);
34 assert.strictEqual(writable._writableState.bufferedRequestCount, 1);
40 assert.strictEqual(writable._writableState.corked, 1);
41 assert.strictEqual(writable._writableState.bufferedRequestCount, 2);
46 assert.strictEqual(writable._writableState.corked, 0);
47 assert.strictEqual(writable._writableState.bufferedRequestCount, 0);
[all …]
|
| D | test-stream-writable-ended-state.js | 11 assert.strictEqual(writable._writableState.ended, false);
12 assert.strictEqual(writable._writableState.writable, undefined);
17 assert.strictEqual(writable._writableState.ended, false);
18 assert.strictEqual(writable._writableState.writable, undefined);
23 assert.strictEqual(writable._writableState.ended, true);
24 assert.strictEqual(writable._writableState.writable, undefined);
29 assert.strictEqual(writable._writableState.ended, true);
30 assert.strictEqual(writable._writableState.writable, undefined);
|
| /third_party/node/lib/internal/streams/ |
| D | writable.js | 209 return object && object._writableState instanceof WritableState;
234 this._writableState = new WritableState(options, this, isDuplex);
259 const state = this._writableState;
307 this._writableState.corked++;
311 const state = this._writableState;
327 this._writableState.defaultEncoding = encoding;
395 const state = stream._writableState;
555 const state = this._writableState;
699 return this._writableState ? this._writableState.destroyed : false;
703 if (this._writableState) {
[all …]
|
| /third_party/node/deps/npm/node_modules/readable-stream/lib/ |
| D | _stream_duplex.js | 81 return this._writableState.highWaterMark;
90 return this._writableState && this._writableState.getBuffer();
99 return this._writableState.length;
105 if (this._writableState.ended) return; // no more data can be written.
121 if (this._readableState === undefined || this._writableState === undefined) {
125 return this._readableState.destroyed && this._writableState.destroyed;
130 if (this._readableState === undefined || this._writableState === undefined) {
137 this._writableState.destroyed = value;
|
| D | _stream_writable.js | 220 return object && object._writableState instanceof WritableState;
241 this._writableState = new WritableState(options, this, isDuplex); // legacy.
289 var state = this._writableState;
313 this._writableState.corked++;
317 var state = this._writableState;
329 this._writableState.defaultEncoding = encoding;
339 return this._writableState && this._writableState.getBuffer();
357 return this._writableState.highWaterMark;
423 stream._writableState.errorEmitted = true;
429 stream._writableState.errorEmitted = true;
[all …]
|
| /third_party/node/deps/npm/node_modules/fs-write-stream-atomic/node_modules/readable-stream/lib/ |
| D | _stream_duplex.js | 86 return this._writableState.highWaterMark;
94 if (this.allowHalfOpen || this._writableState.ended) return;
107 if (this._readableState === undefined || this._writableState === undefined) {
110 return this._readableState.destroyed && this._writableState.destroyed;
115 if (this._readableState === undefined || this._writableState === undefined) {
122 this._writableState.destroyed = value;
|
| /third_party/node/deps/npm/node_modules/concat-stream/node_modules/readable-stream/lib/ |
| D | _stream_duplex.js | 86 return this._writableState.highWaterMark;
94 if (this.allowHalfOpen || this._writableState.ended) return;
107 if (this._readableState === undefined || this._writableState === undefined) {
110 return this._readableState.destroyed && this._writableState.destroyed;
115 if (this._readableState === undefined || this._writableState === undefined) {
122 this._writableState.destroyed = value;
|
| D | _stream_writable.js | 241 return object && object._writableState instanceof WritableState;
264 this._writableState = new WritableState(options, this);
315 var state = this._writableState;
341 var state = this._writableState;
347 var state = this._writableState;
360 this._writableState.defaultEncoding = encoding;
377 return this._writableState.highWaterMark;
442 stream._writableState.errorEmitted = true;
448 stream._writableState.errorEmitted = true;
464 var state = stream._writableState;
[all …]
|
| /third_party/node/deps/npm/node_modules/through2/node_modules/readable-stream/lib/ |
| D | _stream_duplex.js | 86 return this._writableState.highWaterMark;
94 if (this.allowHalfOpen || this._writableState.ended) return;
107 if (this._readableState === undefined || this._writableState === undefined) {
110 return this._readableState.destroyed && this._writableState.destroyed;
115 if (this._readableState === undefined || this._writableState === undefined) {
122 this._writableState.destroyed = value;
|
| /third_party/node/deps/npm/node_modules/parallel-transform/node_modules/readable-stream/lib/ |
| D | _stream_duplex.js | 86 return this._writableState.highWaterMark;
94 if (this.allowHalfOpen || this._writableState.ended) return;
107 if (this._readableState === undefined || this._writableState === undefined) {
110 return this._readableState.destroyed && this._writableState.destroyed;
115 if (this._readableState === undefined || this._writableState === undefined) {
122 this._writableState.destroyed = value;
|
| /third_party/node/deps/npm/node_modules/flush-write-stream/node_modules/readable-stream/lib/ |
| D | _stream_duplex.js | 86 return this._writableState.highWaterMark;
94 if (this.allowHalfOpen || this._writableState.ended) return;
107 if (this._readableState === undefined || this._writableState === undefined) {
110 return this._readableState.destroyed && this._writableState.destroyed;
115 if (this._readableState === undefined || this._writableState === undefined) {
122 this._writableState.destroyed = value;
|
| /third_party/node/deps/npm/node_modules/stream-iterate/node_modules/readable-stream/lib/ |
| D | _stream_duplex.js | 86 return this._writableState.highWaterMark;
94 if (this.allowHalfOpen || this._writableState.ended) return;
107 if (this._readableState === undefined || this._writableState === undefined) {
110 return this._readableState.destroyed && this._writableState.destroyed;
115 if (this._readableState === undefined || this._writableState === undefined) {
122 this._writableState.destroyed = value;
|
| /third_party/node/deps/npm/node_modules/duplexify/node_modules/readable-stream/lib/ |
| D | _stream_duplex.js | 86 return this._writableState.highWaterMark;
94 if (this.allowHalfOpen || this._writableState.ended) return;
107 if (this._readableState === undefined || this._writableState === undefined) {
110 return this._readableState.destroyed && this._writableState.destroyed;
115 if (this._readableState === undefined || this._writableState === undefined) {
122 this._writableState.destroyed = value;
|
| /third_party/node/deps/npm/node_modules/are-we-there-yet/node_modules/readable-stream/lib/ |
| D | _stream_duplex.js | 86 return this._writableState.highWaterMark;
94 if (this.allowHalfOpen || this._writableState.ended) return;
107 if (this._readableState === undefined || this._writableState === undefined) {
110 return this._readableState.destroyed && this._writableState.destroyed;
115 if (this._readableState === undefined || this._writableState === undefined) {
122 this._writableState.destroyed = value;
|
| /third_party/node/deps/npm/node_modules/from2/node_modules/readable-stream/lib/ |
| D | _stream_duplex.js | 86 return this._writableState.highWaterMark;
94 if (this.allowHalfOpen || this._writableState.ended) return;
107 if (this._readableState === undefined || this._writableState === undefined) {
110 return this._readableState.destroyed && this._writableState.destroyed;
115 if (this._readableState === undefined || this._writableState === undefined) {
122 this._writableState.destroyed = value;
|
1234