		@@ -29,10 +29,10 @@ /**

		this.readable = readable;
		this.writable = writable;
		this.source = readable;
		this.sink = writable;

		this.readable.on('end', _.bind(function() { this.push(null); }, this));
		this.readable.on('readable', _.bind(function() { this.read(0); }, this));
		this.readable.on('error', _.bind(function(err) { this.emit('error', err); }, this));
		this.writable.on('error', _.bind(function(err) { this.emit('error', err); }, this));
		this. on('finish', _.bind(function() { this.writable.end(); }, this));
		this.source.on('end', _.bind(function() { this.push(null); }, this));
		this.source.on('readable', _.bind(function() { this.read(0); }, this));
		this.source.on('error', _.bind(function(err) { this.emit('error', err); }, this));
		this.sink .on('error', _.bind(function(err) { this.emit('error', err); }, this));
		this. on('finish', _.bind(function() { this.sink.end(); }, this));
		}
		@@ -43,3 +43,3 @@
		SimpleDuplex.prototype._read = function(size) {
		var chunk = this.readable.read(size);
		var chunk = this.source.read(size);
		this.push(chunk === null ? '' : chunk);
		@@ -50,3 +50,3 @@ return chunk;
		SimpleDuplex.prototype._write = function(chunk, encoding, callback) {
		return this.writable.write(chunk, encoding, callback);
		return this.sink.write(chunk, encoding, callback);
		};
		@@ -53,0 +53,0 @@

03_compress_custom.c

output1.xz

output2.xz

simple.js

simpleout.xz

test.js

lzma-native - npm Package Compare versions

New alerts