Update reads on readable events

Author: alexpenev-s

examples/app3.js

@@ -52,8 +52,8 @@ function fetchRows(rs, cb) {
 
   function onreadable() {
     /* jshint validthis:true */
-    var chunk = this.read();
-    if (chunk) {
+    var chunk;
+    while (null !== (chunk = this.read())) {
       rows.push(chunk);
     }
   }

examples/app7.js

@@ -107,8 +107,8 @@ function fetch(rs, cb) {
 
   function read() {
     /* jshint validthis:true */
-    var row = this.read();
-    if (row) {
+    var row;
+    while (null !== (row = this.read())) {
       rows.push(row);
     }
   }

test/acceptance/db.Query.js

@@ -73,8 +73,8 @@ describe('db', function () {
           readable.once('error', function onerror() {
             done(err);
           }).on('readable', function onreadable() {
-            var chunk = this.read();
-            if (chunk) {
+            var chunk;
+            while (null !== (chunk = this.read())) {
               rows = rows.concat(chunk);
             }
           }).once('end', function onend() {

test/lib.Lob.js

@@ -95,8 +95,8 @@ describe('Lib', function () {
       var stream = lob.createReadStream();
       var chunks = [];
       stream.on('readable', function () {
-        var chunk = stream.read();
-        if (chunk) {
+        var chunk;
+        while (null !== (chunk = stream.read())) {
           chunks.push(chunk);
         }
         if (chunks.length === 3) {

test/lib.ResultSet.js

@@ -93,10 +93,10 @@ ConnectionMock.prototype.fetchNext = function fetchNext(options, cb) {
 function readSimpleStream(rs, stream, cb) {
   var chunks = [];
   stream.on('readable', function onreadable() {
-    var chunk = stream.read();
-    if (chunk !== null) {
-      chunks.push(chunk);
-    }
+     var chunk;
+     while (null !== (chunk = stream.read())) {
+       chunks.push(chunk);
+     }
   });
   rs.once('error', function onerror(err) {
     cb(err);

test/lib.ResultSetTransform.js

@@ -120,8 +120,8 @@ describe('Lib', function () {
       });
       var chunks = [];
       rst.on('readable', function () {
-        var value = rst.read();
-        if (value !== null) {
+        var value;
+        while ((value = rst.read()) !== null) {
           chunks.push(Buffer.from([value]));
         }
       });
@@ -143,8 +143,8 @@ describe('Lib', function () {
       });
       var chunks = [];
       rst.on('readable', function () {
-        var value = rst.read();
-        if (value !== null) {
+        var value;
+        while ((value = rst.read()) !== null) {
           chunks.push(Buffer.from(value));
         }
       });
@@ -167,8 +167,8 @@ describe('Lib', function () {
       });
       var chunks = [];
       rst.on('readable', function () {
-        var value = rst.read();
-        if (value !== null) {
+        var value;
+        while ((value = rst.read()) !== null) {
           chunks.push(Buffer.from(value));
         }
       });

test/lib.Stringifier.js

@@ -73,11 +73,11 @@ function testStringifier(chunks, rows, done) {
   stringifier.on('error', function (err) {
     done(err);
   }).on('readable', function () {
-    var chunk = this.read();
-    if (chunk) {
+    var chunk;
+    while (null !== (chunk = this.read())) {
       data += chunk;
     }
-  }).on('finish', function () {
+  }).on('end', function () {
     JSON.parse(data).should.eql(rows);
     done();
   });

test/util.index.js

@@ -57,10 +57,14 @@ describe('Util', function () {
 
       var chunks = [];
       readable.on('readable', function () {
-        var chunk = this.read();
-        if (chunk !== null) {
+        var chunk;
+        var emit = false;
+        while (null !== (chunk = this.read())) {
           var value = chunk[0];
           chunks.unshift(value);
+          emit = true;
+        }
+        if (emit) {
           emitData();
         }
       });