Merge pull request #18 from marsaud/master

BufferStreams emit finish and readable event
samcday · May 28, 2015 · 93914f8 · 93914f8
2 parents 7d8bc24 + 346e0da
commit 93914f8
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/lib/readable_streambuffer.js b/lib/readable_streambuffer.js
@@ -71,6 +71,7 @@ var ReadableStreamBuffer = module.exports = function(opts) {
 	this.put = function(data, encoding) {
 		if(!that.readable) return;
 
+		var wasEmpty = size === 0;
 		if(Buffer.isBuffer(data)) {
 			increaseBufferIfNecessary(data.length);
 			data.copy(buffer, size, 0);
@@ -84,6 +85,10 @@ var ReadableStreamBuffer = module.exports = function(opts) {
 			size += dataSizeInBytes;
 		}
 
+		if (wasEmpty && size > 0) {
+			this.emit('readable')
+		}
+
 		if (!this.isPaused && !frequency) {
 			while (size > 0) {
 				sendData();

diff --git a/lib/writable_streambuffer.js b/lib/writable_streambuffer.js
@@ -85,6 +85,7 @@ var WritableStreamBuffer = module.exports = function(opts) {
 	this.end = function() {
 		var args = Array.prototype.slice.apply(arguments);
 		if(args.length) that.write.apply(that, args);
+		that.emit('finish');
 		that.destroy();
 	};