msgpack-rpc-lite - npm Package Compare versions

Comparing version 0.0.2 to 0.0.3

index.js

		@@ -92,3 +92,3 @@ /*
		function _call(type, method, ...args) {
		const callback = typeof args.slice(-1) === 'function' && args.pop();
		const callback = typeof args[args.length - 1] === 'function' && args.pop();
		const params = args;
		@@ -95,0 +95,0 @@ const message = [ type ].concat(type === 0 ? msgidGenerator.next() : [], method, [ params ] );

package.json

		{
		"name": "msgpack-rpc-lite",
		"version": "0.0.2",
		"version": "0.0.3",
		"description": "Implementation of MessagePack-RPC with msgpack-lite",
		@@ -5,0 +5,0 @@ "main": "index.js",

test/index.js

		@@ -6,3 +6,3 @@ const expect = require('chai').expect;

		describe('msgpack-rpc', () => {
		describe('msgpack-rpc#request', () => {

		@@ -21,3 +21,3 @@ const option = { port: Number(process.env.npm_package_config_test_port \|\| 9199) };

		it('msgpack-rpc#call', done => {
		it('call', done => {
		portfinder.getPortPromise(option).then(port => {
		@@ -40,6 +40,44 @@ debug({ port });

		it('msgpack-rpc#notify', done => {
		it('should be empty when call without arguments', done => {
		portfinder.getPortPromise(option).then(port => {
		debug({ port });

		server = rpc.createServer().on('foo', (params, callback) => {
		expect(params).to.be.a('array').and.to.have.property('length', 0);
		callback(null, params.length);
		});
		server.listen(port);

		client = rpc.createClient(port);
		return new Promise((resolve, reject) => {
		client.request('foo', (error, response, msgid) => {
		if (error) { reject(error); } else { resolve([ response, msgid ]); }
		});
		});
		}).then(([ response ]) => {
		expect(response).to.have.ordered.members([ 0 ]);
		done();
		}).catch(done);
		});

		});

		describe('msgpack-rpc#notify', () => {

		const option = { port: Number(process.env.npm_package_config_test_port \|\| 9199) };
		let server;
		let client;

		afterEach(done => {
		client && client.close();
		client = null;
		server && server.close();
		server = null;
		done();
		});

		it('notify', done => {
		portfinder.getPortPromise(option).then(port => {
		debug({ port });

		server = rpc.createServer().on('qux', params => {
		@@ -46,0 +84,0 @@ expect(params).to.have.ordered.members([ 1, 2, 3 ]);

New alerts