Searched refs:errorEmitted (Results 1 – 25 of 33) sorted by relevance
12
| /third_party/node/test/parallel/ |
| D | test-stream-readable-destroy.js | 136 assert.strictEqual(read._readableState.errorEmitted, true);
142 assert.strictEqual(read._readableState.errorEmitted, false);
186 assert.strictEqual(read._readableState.errorEmitted, true);
194 assert.strictEqual(read._readableState.errorEmitted, false);
200 assert.strictEqual(read._readableState.errorEmitted, false);
216 assert.strictEqual(readable._readableState.errorEmitted, true);
221 assert.strictEqual(readable._readableState.errorEmitted, true);
227 assert.strictEqual(readable._readableState.errorEmitted, false);
232 assert.strictEqual(readable._readableState.errorEmitted, false);
|
| D | test-http-client-close-event.js | 15 let errorEmitted = false; variable
18 errorEmitted = true;
26 assert.strictEqual(errorEmitted, true);
|
| D | test-stream2-readable-wrap-error.js | 19 assert.strictEqual(r._readableState.errorEmitted, true);
32 assert.strictEqual(r._readableState.errorEmitted, true);
|
| D | test-stream-writable-destroy.js | 167 assert.strictEqual(write._writableState.errorEmitted, true);
174 assert.strictEqual(write._writableState.errorEmitted, false);
194 assert.strictEqual(writable._writableState.errorEmitted, true);
199 assert.strictEqual(writable._writableState.errorEmitted, true);
205 assert.strictEqual(writable._writableState.errorEmitted, false);
210 assert.strictEqual(writable._writableState.errorEmitted, false);
|
| /third_party/node/deps/npm/node_modules/readable-stream/lib/internal/streams/ |
| D | destroy.js | 15 } else if (!this._writableState.errorEmitted) {
16 this._writableState.errorEmitted = true;
39 } else if (!_this._writableState.errorEmitted) {
40 _this._writableState.errorEmitted = true;
82 this._writableState.errorEmitted = false;
|
| /third_party/node/lib/internal/streams/ |
| D | destroy.js | 95 if ((w && w.errorEmitted) || (r && r.errorEmitted)) {
100 w.errorEmitted = true;
103 r.errorEmitted = true;
118 r.errorEmitted = false;
134 w.errorEmitted = false;
|
| D | readable.js | 120 this.errorEmitted = false;
746 if (s && !s.errorEmitted) {
1108 let errorEmitted = state.errorEmitted;
1116 errorEmitted = true;
1133 } else if (errorEmitted) {
1165 return !!r && r.readable !== false && !r.destroyed && !r.errorEmitted &&
1182 this._readableState.errorEmitted ||
1330 if (!state.errorEmitted && !state.closeEmitted &&
|
| D | end-of-stream.js | 155 (wState && wState.errorEmitted) ||
156 (rState && rState.errorEmitted) ||
|
| /third_party/node/deps/npm/node_modules/concat-stream/node_modules/readable-stream/lib/internal/streams/ |
| D | destroy.js | 18 } else if (err && (!this._writableState || !this._writableState.errorEmitted)) {
40 _this._writableState.errorEmitted = true;
63 this._writableState.errorEmitted = false;
|
| /third_party/node/deps/npm/node_modules/are-we-there-yet/node_modules/readable-stream/lib/internal/streams/ |
| D | destroy.js | 18 } else if (err && (!this._writableState || !this._writableState.errorEmitted)) {
40 _this._writableState.errorEmitted = true;
63 this._writableState.errorEmitted = false;
|
| /third_party/node/deps/npm/node_modules/through2/node_modules/readable-stream/lib/internal/streams/ |
| D | destroy.js | 18 } else if (err && (!this._writableState || !this._writableState.errorEmitted)) {
40 _this._writableState.errorEmitted = true;
63 this._writableState.errorEmitted = false;
|
| /third_party/node/deps/npm/node_modules/fs-write-stream-atomic/node_modules/readable-stream/lib/internal/streams/ |
| D | destroy.js | 18 } else if (err && (!this._writableState || !this._writableState.errorEmitted)) {
40 _this._writableState.errorEmitted = true;
63 this._writableState.errorEmitted = false;
|
| /third_party/node/deps/npm/node_modules/duplexify/node_modules/readable-stream/lib/internal/streams/ |
| D | destroy.js | 18 } else if (err && (!this._writableState || !this._writableState.errorEmitted)) {
40 _this._writableState.errorEmitted = true;
63 this._writableState.errorEmitted = false;
|
| /third_party/node/deps/npm/node_modules/parallel-transform/node_modules/readable-stream/lib/internal/streams/ |
| D | destroy.js | 18 } else if (err && (!this._writableState || !this._writableState.errorEmitted)) {
40 _this._writableState.errorEmitted = true;
63 this._writableState.errorEmitted = false;
|
| /third_party/node/deps/npm/node_modules/flush-write-stream/node_modules/readable-stream/lib/internal/streams/ |
| D | destroy.js | 18 } else if (err && (!this._writableState || !this._writableState.errorEmitted)) {
40 _this._writableState.errorEmitted = true;
63 this._writableState.errorEmitted = false;
|
| /third_party/node/deps/npm/node_modules/from2/node_modules/readable-stream/lib/internal/streams/ |
| D | destroy.js | 18 } else if (err && (!this._writableState || !this._writableState.errorEmitted)) {
40 _this._writableState.errorEmitted = true;
63 this._writableState.errorEmitted = false;
|
| /third_party/node/deps/npm/node_modules/stream-iterate/node_modules/readable-stream/lib/internal/streams/ |
| D | destroy.js | 18 } else if (err && (!this._writableState || !this._writableState.errorEmitted)) {
40 _this._writableState.errorEmitted = true;
63 this._writableState.errorEmitted = false;
|
| /third_party/node/deps/npm/node_modules/readable-stream/lib/ |
| D | _stream_writable.js | 176 this.errorEmitted = false; // Should close be emitted on destroy. Defaults to true.
423 stream._writableState.errorEmitted = true;
429 stream._writableState.errorEmitted = true;
|
| /third_party/node/deps/npm/node_modules/through2/node_modules/readable-stream/lib/ |
| D | _stream_writable.js | 201 this.errorEmitted = false;
442 stream._writableState.errorEmitted = true;
448 stream._writableState.errorEmitted = true;
|
| /third_party/node/deps/npm/node_modules/fs-write-stream-atomic/node_modules/readable-stream/lib/ |
| D | _stream_writable.js | 201 this.errorEmitted = false;
442 stream._writableState.errorEmitted = true;
448 stream._writableState.errorEmitted = true;
|
| /third_party/node/deps/npm/node_modules/flush-write-stream/node_modules/readable-stream/lib/ |
| D | _stream_writable.js | 201 this.errorEmitted = false;
442 stream._writableState.errorEmitted = true;
448 stream._writableState.errorEmitted = true;
|
| /third_party/node/deps/npm/node_modules/from2/node_modules/readable-stream/lib/ |
| D | _stream_writable.js | 201 this.errorEmitted = false;
442 stream._writableState.errorEmitted = true;
448 stream._writableState.errorEmitted = true;
|
| /third_party/node/deps/npm/node_modules/parallel-transform/node_modules/readable-stream/lib/ |
| D | _stream_writable.js | 201 this.errorEmitted = false;
442 stream._writableState.errorEmitted = true;
448 stream._writableState.errorEmitted = true;
|
| /third_party/node/deps/npm/node_modules/concat-stream/node_modules/readable-stream/lib/ |
| D | _stream_writable.js | 201 this.errorEmitted = false;
442 stream._writableState.errorEmitted = true;
448 stream._writableState.errorEmitted = true;
|
| /third_party/node/deps/npm/node_modules/duplexify/node_modules/readable-stream/lib/ |
| D | _stream_writable.js | 201 this.errorEmitted = false;
442 stream._writableState.errorEmitted = true;
448 stream._writableState.errorEmitted = true;
|
12