Revert "stream: Never call decoder.end() multiple times"

This reverts commit 615d809ac684a7d2cc7ee5e1aa58f0a921b529a0.

diff --git a/lib/_stream_readable.js b/lib/_stream_readable.js
index c669455d7d96685a23028d7af98628709c852e28..b09694c071556e81c8df91a16e8299ca97da25ba 100644 (file)
--- a/lib/_stream_readable.js
+++ b/lib/_stream_readable.js
@@ -349,7 +349,6 @@ function onEofChunk(stream, state) {
       state.buffer.push(chunk);
       state.length += state.objectMode ? 1 : chunk.length;
     }
-    state.decoder = null;
   }
 
   // if we've ended and we have some data left, then emit

diff --git a/test/simple/test-stream2-set-encoding.js b/test/simple/test-stream2-set-encoding.js
index ad4d8846801305a462cf8b9f2f06d2cd729ad8a4..8c5973fb6371e9e94cc78f77d4c93b0abea0820e 100644 (file)
--- a/test/simple/test-stream2-set-encoding.js
+++ b/test/simple/test-stream2-set-encoding.js
@@ -163,10 +163,6 @@ test('setEncoding hex', function(t) {
 
   // just kick it off.
   tr.emit('readable');
-
-  process.on('exit', function() {
-    assert(!tr._readableState.decoder);
-  });
 });
 
 test('setEncoding hex with read(13)', function(t) {