Merge pull request #15 from vmpowerio/fix-14

Call end() on readable stream buffer to enable piping

Author: Steven Edouard

index.js

@@ -96,6 +96,7 @@ class ChartjsNode {
                 chunkSize: 2048     // in bytes.
             });
             readableStream.put(buffer);
+            readableStream.stop();
             return {
                 stream: readableStream,
                 length: buffer.length

test/index.js

@@ -104,7 +104,22 @@ describe('chartjs', function () {
             })
             .then(imageStream => {
                 assert(imageStream.stream instanceof stream.Readable);
-                debug('Sucessfully wrote image to a Readable stream');
+                var length = imageStream.length;
+                var readLength = 0;
+                return new Promise((resolve, reject) => {
+                    imageStream.stream.on('data', d => {
+                        readLength += d.length;
+                        if (readLength === length) {
+                            debug('Sucessfully wrote image to a Readable stream');
+                            resolve();
+                        }
+                    });
+                    setTimeout(() => {
+                        debug('length: ' + length);
+                        debug('readLength: ' + readLength);
+                        reject('Failed to read complete chart image stream in time');
+                    }, 1000);
+                });
             });
         });
         it('should return the image as data url', function () {