burro - npm Package Compare versions

Comparing version 0.4.4 to 0.4.5

lib/framer.js

		@@ -9,3 +9,3 @@ var stream = require("stream"),

		Framer.prototype._transform = function _transform(chunk, encoding, callback) {
		Framer.prototype._transform = function _transform(chunk, encoding, done) {
		// <Buffer 0 0 0 0 0 0 0 0 0 0 0 0>
		@@ -25,3 +25,3 @@ var buf = new Buffer(chunk.length + 4);
		// return
		callback(null);
		done(null);
		};

package.json

		{
		"name": "burro",
		"version": "0.4.4",
		"version": "0.4.5",
		"description": "auto-packaged, length-prefixed JSON byte streams",
		@@ -5,0 +5,0 @@ "main": "lib/burro",

test/decoder_test.js

		@@ -17,3 +17,3 @@ var assert = require("assert"),
		var expected = "hello";
		writable._write = function(chunk, _) {
		writable._write = function(chunk, encoding, callback) {
		assert.strictEqual(chunk, expected);
		@@ -27,3 +27,3 @@ done();
		var expected = {a: "b", c: "d"};
		writable._write = function(chunk, _) {
		writable._write = function(chunk, encoding, callback) {
		assert.deepEqual(chunk, expected);
		@@ -30,0 +30,0 @@ done();

test/encoder_test.js

		@@ -17,3 +17,3 @@ var assert = require("assert"),
		var expected = "hello";
		writable._write = function(chunk, _) {
		writable._write = function(chunk, encoding, callback) {
		assert.strictEqual(chunk, JSON.stringify(expected));
		@@ -27,3 +27,3 @@ done();
		var expected = {a: "b", c: "d"};
		writable._write = function(chunk, _) {
		writable._write = function(chunk, encoding, callback) {
		assert.strictEqual(chunk, JSON.stringify(expected));
		@@ -30,0 +30,0 @@ done();

test/framer_test.js

		@@ -17,3 +17,3 @@ var assert = require("assert"),
		var expected = Buffer([255,255,255,255]);
		writable._write = function(chunk, _) {
		writable._write = function(chunk, encoding, callback) {
		assert.deepEqual(chunk, Buffer([0,0,0,4,255,255,255,255]));
		@@ -20,0 +20,0 @@ done();

test/integration_test.js

		@@ -11,3 +11,3 @@ var assert = require("assert"),
		bob = new stream.Readable({objectMode: true});
		bob._read = function _read() {};
		bob._read = function _read(bytes) {};
		alice = new stream.Writable({objectMode: true});
		@@ -20,3 +20,3 @@ socket = burro.wrap(new stream.PassThrough());
		var expected = "hello world";
		alice._write = function(obj, encoding, _) {
		alice._write = function(obj, encoding, callback) {
		assert.strictEqual(obj, expected);
		@@ -30,3 +30,3 @@ done();
		var expected = {a: "a", b: "b"};
		alice._write = function(obj, encoding, _) {
		alice._write = function(obj, encoding, callback) {
		assert.deepEqual(obj, expected);
		@@ -46,3 +46,3 @@ done();
		};
		alice._write = function(obj, encoding, _) {
		alice._write = function(obj, encoding, callback) {
		assert.deepEqual(obj, expected);
		@@ -60,8 +60,8 @@ done();
		];
		alice._write = function(obj, encoding, _done) {
		alice._write = function(obj, encoding, callback) {
		assert.deepEqual(obj, expected.shift());
		_done();
		if (expected.length === 0) {
		done();
		}
		callback();
		};
		@@ -75,3 +75,3 @@ expected.forEach(function(obj) {
		var expected = "どうもありがとう";
		alice._write = function(obj, encoding, _) {
		alice._write = function(obj, encoding, callback) {
		assert.strictEqual(obj, expected);
		@@ -85,3 +85,3 @@ done();
		var expected;
		alice._write = function(obj, encoding, _) {
		alice._write = function(obj, encoding, callback) {
		assert.strictEqual(obj, expected);
		@@ -88,0 +88,0 @@ done();

test/unframer_test.js

		@@ -21,3 +21,3 @@ var assert = require("assert"),
		var expected = Buffer([255,255,255,255]);
		writable._write = function(chunk, encoding, _) {
		writable._write = function(chunk, encoding, callback) {
		assert.deepEqual(chunk, expected);
		@@ -31,3 +31,3 @@ done();
		var expected = Buffer([255,255,255,255]);
		writable._write = function(chunk, encoding, _) {
		writable._write = function(chunk, encoding, callback) {
		assert.deepEqual(chunk, expected);
		@@ -34,0 +34,0 @@ done();

New alerts