		@@ -135,4 +135,9 @@ 'use strict';
		* @param {Function} callback
		* @return {undefined}
		*/
		KinesisWritable.prototype._flush = function _flush(callback) {
		if (this.queue.length === 0) {
		return callback();
		}

		var retry = retryFn.bind(null, {
		@@ -139,0 +144,0 @@ retries: this.maxRetries,

package.json

		{
		"name": "kinesis-write-stream",
		"version": "0.0.1",
		"version": "1.0.0",
		"description": "Kinesis writable stream that buffers up records",
		@@ -5,0 +5,0 @@ "main": "index.js",

README.md

		@@ -13,3 +13,3 @@ # kinesis-write-stream
		Records written to the stream will buffer up until `highWaterMark` has
		been reached or the stream is closed before writing to Kinesis using
		been reached, or the stream is closed, before writing to Kinesis using
		`putRecords`.
		@@ -16,0 +16,0 @@

test/kinesis-write-stream.js

		@@ -89,2 +89,18 @@ 'use strict';

		it('should do nothing if there is nothing in the queue when the stream is closed', function(done) {
		this.client.putRecords.yields(null, successResponseFixture);

		this.stream.on('finish', function() {
		expect(this.client.putRecords).to.have.been.calledOnce;

		done();
		}.bind(this));

		for (var i = 0; i < 6; i++) {
		this.stream.write(recordsFixture);
		}

		this.stream.end();
		});

		it('should buffer records up to highWaterMark', function(done) {
		@@ -91,0 +107,0 @@ this.client.putRecords.yields(null, successResponseFixture);

.tern-port

kinesis-write-stream - npm Package Compare versions

New alerts