| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
1 parent 80a26c7 commit ba4a3ed
2 files changed
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -43,6 +43,7 @@ function WritableState(options, stream) { | |||
| 43 | 43 | // cast to ints. | |
| 44 | 44 | this.highWaterMark = ~~this.highWaterMark; | |
| 45 | 45 | ||
| 46 | + // drain event flag. | ||
| 46 | 47 | this.needDrain = false; | |
| 47 | 48 | // at the start of calling end() | |
| 48 | 49 | this.ending = false; | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -0,0 +1,34 @@ | |||
| 1 | + 'use strict'; | ||
| 2 | + | ||
| 3 | + require('../common'); | ||
| 4 | + | ||
| 5 | + const assert = require('assert'); | ||
| 6 | + const stream = require('stream'); | ||
| 7 | + | ||
| 8 | + const writable = new stream.Writable(); | ||
| 9 | + | ||
| 10 | + function testStates(ending, finished, ended) { | ||
| 11 | + assert.strictEqual(writable._writableState.ending, ending); | ||
| 12 | + assert.strictEqual(writable._writableState.finished, finished); | ||
| 13 | + assert.strictEqual(writable._writableState.ended, ended); | ||
| 14 | + } | ||
| 15 | + | ||
| 16 | + writable._write = (chunk, encoding, cb) => { | ||
| 17 | + // ending, finished, ended start in false. | ||
| 18 | + testStates(false, false, false); | ||
| 19 | + cb(); | ||
| 20 | + }; | ||
| 21 | + | ||
| 22 | + writable.on('finish', () => { | ||
| 23 | + // ending, finished, ended = true. | ||
| 24 | + testStates(true, true, true); | ||
| 25 | + }); | ||
| 26 | + | ||
| 27 | + writable.end('testing function end()', () => { | ||
| 28 | + // ending, finished, ended = true. | ||
| 29 | + testStates(true, true, true); | ||
| 30 | + }); | ||
| 31 | + | ||
| 32 | + // ending, ended = true. | ||
| 33 | + // finished = false. | ||
| 34 | + testStates(true, false, true); | ||
| Back | FazBrowse Home | New Git URL |
0 commit comments