diff options
Diffstat (limited to 'test/parallel/test-stream-finished.js')
-rw-r--r-- | test/parallel/test-stream-finished.js | 188 |
1 files changed, 3 insertions, 185 deletions
diff --git a/test/parallel/test-stream-finished.js b/test/parallel/test-stream-finished.js index 12a40b35b9..d6361ea303 100644 --- a/test/parallel/test-stream-finished.js +++ b/test/parallel/test-stream-finished.js @@ -101,25 +101,11 @@ const { promisify } = require('util'); const rs = new Readable(); finished(rs, common.mustCall((err) => { - assert(err, 'premature close error'); - })); - - rs.push(null); - rs.emit('close'); - rs.resume(); -} - -{ - const rs = new Readable(); - - finished(rs, common.mustCall((err) => { assert(!err, 'no error'); })); rs.push(null); - rs.on('end', common.mustCall(() => { - rs.emit('close'); // Should not trigger an error - })); + rs.emit('close'); // Should not trigger an error rs.resume(); } @@ -169,9 +155,8 @@ const { promisify } = require('util'); rs.resume(); } +// Test that calling returned function removes listeners { - // Nothing happens if disposed. - const ws = new Writable({ write(data, env, cb) { cb(); @@ -183,8 +168,6 @@ const { promisify } = require('util'); } { - // Nothing happens if disposed. - const rs = new Readable(); const removeListeners = finished(rs, common.mustNotCall()); removeListeners(); @@ -195,174 +178,9 @@ const { promisify } = require('util'); } { - // Completed if readable-like is ended before. - const streamLike = new EE(); streamLike.readableEnded = true; streamLike.readable = true; - finished(streamLike, common.mustCall()); -} - -{ - // Completed if readable-like is never ended. - - const streamLike = new EE(); - streamLike.readableEnded = false; - streamLike.readable = true; - finished(streamLike, common.expectsError({ - code: 'ERR_STREAM_PREMATURE_CLOSE' - })); + finished(streamLike, common.mustCall); streamLike.emit('close'); } - -{ - // Completed if writable-like is destroyed before. - - const streamLike = new EE(); - streamLike.destroyed = true; - streamLike.writable = true; - finished(streamLike, common.mustCall()); -} - -{ - // Completed if readable-like is aborted before. - - const streamLike = new EE(); - streamLike.destroyed = true; - streamLike.readable = true; - finished(streamLike, common.mustCall()); -} - -{ - // Completed if writable-like is aborted before. - - const streamLike = new EE(); - streamLike.aborted = true; - streamLike.writable = true; - finished(streamLike, common.mustCall()); -} - -{ - // Completed if readable-like is aborted before. - - const streamLike = new EE(); - streamLike.aborted = true; - streamLike.readable = true; - finished(streamLike, common.mustCall()); -} - -{ - // Completed if streamlike is finished before. - - const streamLike = new EE(); - streamLike.writableFinished = true; - streamLike.writable = true; - finished(streamLike, common.mustCall()); -} - -{ - // Premature close if stream is not finished. - - const streamLike = new EE(); - streamLike.writableFinished = false; - streamLike.writable = true; - finished(streamLike, common.expectsError({ - code: 'ERR_STREAM_PREMATURE_CLOSE' - })); - streamLike.emit('close'); -} - -{ - // Premature close if stream never emitted 'finish' - // even if writableFinished says something else. - - const streamLike = new EE(); - streamLike.writable = true; - finished(streamLike, common.expectsError({ - code: 'ERR_STREAM_PREMATURE_CLOSE' - })); - streamLike.writableFinished = true; - streamLike.emit('close'); -} - - -{ - // Premature close if stream never emitted 'end' - // even if readableEnded says something else. - - const streamLike = new EE(); - streamLike.readable = true; - finished(streamLike, common.expectsError({ - code: 'ERR_STREAM_PREMATURE_CLOSE' - })); - streamLike.readableEnded = true; - streamLike.emit('close'); -} - -{ - // Completes if already finished. - - const w = new Writable(); - finished(w, common.mustCall(() => { - finished(w, common.mustCall()); - })); - w.destroy(); -} - -{ - // Completes if already ended. - - const r = new Readable(); - finished(r, common.mustCall(() => { - finished(r, common.mustCall()); - })); - r.destroy(); -} - -{ - // Test is readable check through readable - const streamLike = new EE(); - streamLike.readable = false; - finished(streamLike, common.mustCall()); - streamLike.emit('end'); -} - -{ - // Test is readable check through readableEnded - const streamLike = new EE(); - streamLike.readableEnded = true; - finished(streamLike, common.mustCall()); - streamLike.emit('end'); -} - -{ - // Test is readable check through _readableState - const streamLike = new EE(); - streamLike._readableState = {}; - finished(streamLike, common.mustCall()); - streamLike.emit('end'); -} - -{ - // Test is writable check through writable - const streamLike = new EE(); - streamLike.writable = false; - finished(streamLike, common.mustCall()); - streamLike.emit('finish'); -} - -{ - // Test is writable check through writableEnded - const streamLike = new EE(); - streamLike.writableEnded = true; - finished(streamLike, common.mustCall()); - streamLike.emit('finish'); -} - -{ - // Test is writable check through _writableState - const streamLike = new EE(); - streamLike._writableState = {}; - finished(streamLike, common.mustCall()); - streamLike.emit('finish'); -} |