rxws - npm Package Compare versions

Comparing version 3.0.0 to 3.0.1

lib/get.js

 'use strict';
 
-Object.defineProperty(exports, '__esModule', {
+var _extends = Object.assign || function (target) { for (var i = 1; i < arguments.length; i++) { var source = arguments[i]; for (var key in source) { if (Object.prototype.hasOwnProperty.call(source, key)) { target[key] = source[key]; } } } return target; };
+
+Object.defineProperty(exports, "__esModule", {
 	value: true
 });
+exports.default = get;
 
-var _extends = Object.assign || function (target) { for (var i = 1; i < arguments.length; i++) { var source = arguments[i]; for (var key in source) { if (Object.prototype.hasOwnProperty.call(source, key)) { target[key] = source[key]; } } } return target; };
-
-exports['default'] = get;
-
-function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { 'default': obj }; }
-
 var _request = require('./request');
@@ -17,9 +14,9 @@
 
+function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
+
 function get(resourcePath, options) {
-	return (0, _request2['default'])(_extends({}, options, {
+	return (0, _request2.default)(_extends({}, options, {
 		resource: resourcePath,
 		method: 'get'
 	}));
-}
-
-module.exports = exports['default'];
+}

lib/get.spec.js

 'use strict';
 
-function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { 'default': obj }; }
-
 var _get = require('./get');
@@ -13,2 +11,5 @@
 
+function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
+
+/* istanbul ignore next */
 describe('GET', function () {
@@ -23,3 +24,3 @@ var backend = undefined;
 	it('should make a request', function () {
-		(0, _get2['default'])('wow').subscribe(function () {});
+		(0, _get2.default)('wow').subscribe(function () {});
 
@@ -38,3 +39,3 @@ expect(backend.write).toHaveBeenCalled();
 	it('should make a request with parameters', function () {
-		(0, _get2['default'])('users', {
+		(0, _get2.default)('users', {
 			parameters: {
@@ -60,3 +61,3 @@ users: 1234
 	it('should make a request with custom headers', function () {
-		(0, _get2['default'])('users', {
+		(0, _get2.default)('users', {
 			parameters: {
@@ -86,3 +87,3 @@ users: 1234
 	it('should make a request with nested resource', function () {
-		(0, _get2['default'])('users.posts.comments', {
+		(0, _get2.default)('users.posts.comments', {
 			parameters: {
@@ -113,6 +114,6 @@ users: 1234,
 		expect(function () {
-			(0, _get2['default'])('').subscribe(function () {});
+			(0, _get2.default)('').subscribe(function () {});
 		}).toThrow();
 		expect(function () {
-			(0, _get2['default'])('').subscribe(function () {});
+			(0, _get2.default)('').subscribe(function () {});
 		}).toThrowError('Invalid config');
@@ -123,8 +124,8 @@ });
 		expect(function () {
-			(0, _get2['default'])('users.comments').subscribe(function () {});
+			(0, _get2.default)('users.comments').subscribe(function () {});
 		}).toThrow();
 		expect(function () {
-			(0, _get2['default'])('users.comments').subscribe(function () {});
+			(0, _get2.default)('users.comments').subscribe(function () {});
 		}).toThrowError('Invalid params: param is required for resource users');
 	});
 });

lib/head.js

 'use strict';
 
-Object.defineProperty(exports, '__esModule', {
+var _extends = Object.assign || function (target) { for (var i = 1; i < arguments.length; i++) { var source = arguments[i]; for (var key in source) { if (Object.prototype.hasOwnProperty.call(source, key)) { target[key] = source[key]; } } } return target; };
+
+Object.defineProperty(exports, "__esModule", {
 	value: true
 });
+exports.default = head;
 
-var _extends = Object.assign || function (target) { for (var i = 1; i < arguments.length; i++) { var source = arguments[i]; for (var key in source) { if (Object.prototype.hasOwnProperty.call(source, key)) { target[key] = source[key]; } } } return target; };
-
-exports['default'] = head;
-
-function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { 'default': obj }; }
-
 var _request = require('./request');
@@ -17,9 +14,9 @@
 
+function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
+
 function head(resourcePath, options) {
-	return (0, _request2['default'])(_extends({}, options, {
+	return (0, _request2.default)(_extends({}, options, {
 		resource: resourcePath,
 		method: 'head'
 	}));
-}
-
-module.exports = exports['default'];
+}

lib/head.spec.js

 'use strict';
 
-function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { 'default': obj }; }
-
 var _head = require('./head');
@@ -13,2 +11,5 @@
 
+function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
+
+/* istanbul ignore next */
 describe('HEAD', function () {
@@ -23,3 +24,3 @@ var backend = undefined;
 	it('should make a request', function () {
-		(0, _head2['default'])('wow').subscribe(function () {});
+		(0, _head2.default)('wow').subscribe(function () {});
 
@@ -38,3 +39,3 @@ expect(backend.write).toHaveBeenCalled();
 	it('should make a request with parameters', function () {
-		(0, _head2['default'])('users', {
+		(0, _head2.default)('users', {
 			parameters: {
@@ -60,3 +61,3 @@ users: 1234
 	it('should make a request with custom headers', function () {
-		(0, _head2['default'])('users', {
+		(0, _head2.default)('users', {
 			parameters: {
@@ -86,3 +87,3 @@ users: 1234
 	it('should make a request with nested resource', function () {
-		(0, _head2['default'])('users.posts.comments', {
+		(0, _head2.default)('users.posts.comments', {
 			parameters: {
@@ -113,6 +114,6 @@ users: 1234,
 		expect(function () {
-			(0, _head2['default'])('').subscribe(function () {});
+			(0, _head2.default)('').subscribe(function () {});
 		}).toThrow();
 		expect(function () {
-			(0, _head2['default'])('').subscribe(function () {});
+			(0, _head2.default)('').subscribe(function () {});
 		}).toThrowError('Invalid config');
@@ -123,8 +124,8 @@ });
 		expect(function () {
-			(0, _head2['default'])('users.comments').subscribe(function () {});
+			(0, _head2.default)('users.comments').subscribe(function () {});
 		}).toThrow();
 		expect(function () {
-			(0, _head2['default'])('users.comments').subscribe(function () {});
+			(0, _head2.default)('users.comments').subscribe(function () {});
 		}).toThrowError('Invalid params: param is required for resource users');
 	});
 });

lib/patch.js

 'use strict';
 
-Object.defineProperty(exports, '__esModule', {
+var _extends = Object.assign || function (target) { for (var i = 1; i < arguments.length; i++) { var source = arguments[i]; for (var key in source) { if (Object.prototype.hasOwnProperty.call(source, key)) { target[key] = source[key]; } } } return target; };
+
+Object.defineProperty(exports, "__esModule", {
 	value: true
 });
+exports.default = patch;
 
-var _extends = Object.assign || function (target) { for (var i = 1; i < arguments.length; i++) { var source = arguments[i]; for (var key in source) { if (Object.prototype.hasOwnProperty.call(source, key)) { target[key] = source[key]; } } } return target; };
-
-exports['default'] = patch;
-
-function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { 'default': obj }; }
-
 var _request = require('./request');
@@ -17,4 +14,6 @@
 
+function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
+
 function patch(resourcePath, data, options) {
-	return (0, _request2['default'])(_extends({}, options, {
+	return (0, _request2.default)(_extends({}, options, {
 		resource: resourcePath,
@@ -24,4 +23,2 @@ data: data,
 	}));
-}
-
-module.exports = exports['default'];
+}

lib/patch.spec.js

 'use strict';
 
-function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { 'default': obj }; }
-
 var _patch = require('./patch');
@@ -13,2 +11,5 @@
 
+function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
+
+/* istanbul ignore next */
 describe('patch', function () {
@@ -23,3 +24,3 @@ var backend = undefined;
 	it('should make a request', function () {
-		(0, _patch2['default'])('wow', {
+		(0, _patch2.default)('wow', {
 			name: 'Ibn Al-Haytham'
@@ -44,3 +45,3 @@ }).subscribe(function () {});
 	it('should make a request with parameters', function () {
-		(0, _patch2['default'])('users', {
+		(0, _patch2.default)('users', {
 			name: 'Ibn Al-Haytham'
@@ -72,3 +73,3 @@ }, {
 	it('should make a request with custom headers', function () {
-		(0, _patch2['default'])('users', {
+		(0, _patch2.default)('users', {
 			name: 'Ibn Al-Haytham'
@@ -104,3 +105,3 @@ }, {
 	it('should make a request with nested resource', function () {
-		(0, _patch2['default'])('users.posts.comments', {
+		(0, _patch2.default)('users.posts.comments', {
 			name: 'Ibn Al-Haytham'
@@ -137,6 +138,6 @@ }, {
 		expect(function () {
-			(0, _patch2['default'])('').subscribe(function () {});
+			(0, _patch2.default)('').subscribe(function () {});
 		}).toThrow();
 		expect(function () {
-			(0, _patch2['default'])('').subscribe(function () {});
+			(0, _patch2.default)('').subscribe(function () {});
 		}).toThrowError('Invalid config');
@@ -147,8 +148,8 @@ });
 		expect(function () {
-			(0, _patch2['default'])('users.comments').subscribe(function () {});
+			(0, _patch2.default)('users.comments').subscribe(function () {});
 		}).toThrow();
 		expect(function () {
-			(0, _patch2['default'])('users.comments').subscribe(function () {});
+			(0, _patch2.default)('users.comments').subscribe(function () {});
 		}).toThrowError('Invalid params: param is required for resource users');
 	});
 });

lib/post.js

 'use strict';
 
-Object.defineProperty(exports, '__esModule', {
+var _extends = Object.assign || function (target) { for (var i = 1; i < arguments.length; i++) { var source = arguments[i]; for (var key in source) { if (Object.prototype.hasOwnProperty.call(source, key)) { target[key] = source[key]; } } } return target; };
+
+Object.defineProperty(exports, "__esModule", {
 	value: true
 });
+exports.default = post;
 
-var _extends = Object.assign || function (target) { for (var i = 1; i < arguments.length; i++) { var source = arguments[i]; for (var key in source) { if (Object.prototype.hasOwnProperty.call(source, key)) { target[key] = source[key]; } } } return target; };
-
-exports['default'] = post;
-
-function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { 'default': obj }; }
-
 var _request = require('./request');
@@ -17,4 +14,6 @@
 
+function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
+
 function post(resourcePath, data, options) {
-	return (0, _request2['default'])(_extends({}, options, {
+	return (0, _request2.default)(_extends({}, options, {
 		resource: resourcePath,
@@ -24,4 +23,2 @@ data: data,
 	}));
-}
-
-module.exports = exports['default'];
+}

lib/post.spec.js

 'use strict';
 
-function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { 'default': obj }; }
-
 var _post = require('./post');
@@ -13,2 +11,5 @@
 
+function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
+
+/* istanbul ignore next */
 describe('POST', function () {
@@ -23,3 +24,3 @@ var backend = undefined;
 	it('should make a request', function () {
-		(0, _post2['default'])('wow', {
+		(0, _post2.default)('wow', {
 			name: 'Ibn Al-Haytham'
@@ -44,3 +45,3 @@ }).subscribe(function () {});
 	it('should make a request with parameters', function () {
-		(0, _post2['default'])('users', {
+		(0, _post2.default)('users', {
 			name: 'Ibn Al-Haytham'
@@ -72,3 +73,3 @@ }, {
 	it('should make a request with custom headers', function () {
-		(0, _post2['default'])('users', {
+		(0, _post2.default)('users', {
 			name: 'Ibn Al-Haytham'
@@ -104,3 +105,3 @@ }, {
 	it('should make a request with nested resource', function () {
-		(0, _post2['default'])('users.posts.comments', {
+		(0, _post2.default)('users.posts.comments', {
 			name: 'Ibn Al-Haytham'
@@ -137,6 +138,6 @@ }, {
 		expect(function () {
-			(0, _post2['default'])('').subscribe(function () {});
+			(0, _post2.default)('').subscribe(function () {});
 		}).toThrow();
 		expect(function () {
-			(0, _post2['default'])('').subscribe(function () {});
+			(0, _post2.default)('').subscribe(function () {});
 		}).toThrowError('Invalid config');
@@ -147,8 +148,8 @@ });
 		expect(function () {
-			(0, _post2['default'])('users.comments').subscribe(function () {});
+			(0, _post2.default)('users.comments').subscribe(function () {});
 		}).toThrow();
 		expect(function () {
-			(0, _post2['default'])('users.comments').subscribe(function () {});
+			(0, _post2.default)('users.comments').subscribe(function () {});
 		}).toThrowError('Invalid params: param is required for resource users');
 	});
 });

lib/put.js

 'use strict';
 
-Object.defineProperty(exports, '__esModule', {
+var _extends = Object.assign || function (target) { for (var i = 1; i < arguments.length; i++) { var source = arguments[i]; for (var key in source) { if (Object.prototype.hasOwnProperty.call(source, key)) { target[key] = source[key]; } } } return target; };
+
+Object.defineProperty(exports, "__esModule", {
 	value: true
 });
+exports.default = put;
 
-var _extends = Object.assign || function (target) { for (var i = 1; i < arguments.length; i++) { var source = arguments[i]; for (var key in source) { if (Object.prototype.hasOwnProperty.call(source, key)) { target[key] = source[key]; } } } return target; };
-
-exports['default'] = put;
-
-function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { 'default': obj }; }
-
 var _request = require('./request');
@@ -17,4 +14,6 @@
 
+function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
+
 function put(resourcePath, data, options) {
-	return (0, _request2['default'])(_extends({}, options, {
+	return (0, _request2.default)(_extends({}, options, {
 		resource: resourcePath,
@@ -24,4 +23,2 @@ data: data,
 	}));
-}
-
-module.exports = exports['default'];
+}

lib/put.spec.js

 'use strict';
 
-function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { 'default': obj }; }
-
 var _put = require('./put');
@@ -13,2 +11,5 @@
 
+function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
+
+/* istanbul ignore next */
 describe('put', function () {
@@ -23,3 +24,3 @@ var backend = undefined;
 	it('should make a request', function () {
-		(0, _put2['default'])('wow', {
+		(0, _put2.default)('wow', {
 			name: 'Ibn Al-Haytham'
@@ -44,3 +45,3 @@ }).subscribe(function () {});
 	it('should make a request with parameters', function () {
-		(0, _put2['default'])('users', {
+		(0, _put2.default)('users', {
 			name: 'Ibn Al-Haytham'
@@ -72,3 +73,3 @@ }, {
 	it('should make a request with custom headers', function () {
-		(0, _put2['default'])('users', {
+		(0, _put2.default)('users', {
 			name: 'Ibn Al-Haytham'
@@ -104,3 +105,3 @@ }, {
 	it('should make a request with nested resource', function () {
-		(0, _put2['default'])('users.posts.comments', {
+		(0, _put2.default)('users.posts.comments', {
 			name: 'Ibn Al-Haytham'
@@ -137,6 +138,6 @@ }, {
 		expect(function () {
-			(0, _put2['default'])('').subscribe(function () {});
+			(0, _put2.default)('').subscribe(function () {});
 		}).toThrow();
 		expect(function () {
-			(0, _put2['default'])('').subscribe(function () {});
+			(0, _put2.default)('').subscribe(function () {});
 		}).toThrowError('Invalid config');
@@ -147,8 +148,8 @@ });
 		expect(function () {
-			(0, _put2['default'])('users.comments').subscribe(function () {});
+			(0, _put2.default)('users.comments').subscribe(function () {});
 		}).toThrow();
 		expect(function () {
-			(0, _put2['default'])('users.comments').subscribe(function () {});
+			(0, _put2.default)('users.comments').subscribe(function () {});
 		}).toThrowError('Invalid params: param is required for resource users');
 	});
 });

lib/remove.js

 'use strict';
 
-Object.defineProperty(exports, '__esModule', {
+var _extends = Object.assign || function (target) { for (var i = 1; i < arguments.length; i++) { var source = arguments[i]; for (var key in source) { if (Object.prototype.hasOwnProperty.call(source, key)) { target[key] = source[key]; } } } return target; };
+
+Object.defineProperty(exports, "__esModule", {
 	value: true
 });
+exports.default = remove;
 
-var _extends = Object.assign || function (target) { for (var i = 1; i < arguments.length; i++) { var source = arguments[i]; for (var key in source) { if (Object.prototype.hasOwnProperty.call(source, key)) { target[key] = source[key]; } } } return target; };
-
-exports['default'] = remove;
-
-function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { 'default': obj }; }
-
 var _request = require('./request');
@@ -17,9 +14,9 @@
 
+function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
+
 function remove(resourcePath, options) {
-	return (0, _request2['default'])(_extends({}, options, {
+	return (0, _request2.default)(_extends({}, options, {
 		resource: resourcePath,
 		method: 'remove'
 	}));
-}
-
-module.exports = exports['default'];
+}

lib/remove.spec.js

 'use strict';
 
-function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { 'default': obj }; }
-
 var _remove = require('./remove');
@@ -13,2 +11,5 @@
 
+function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
+
+/* istanbul ignore next */
 describe('remove', function () {
@@ -23,3 +24,3 @@ var backend = undefined;
 	it('should make a request', function () {
-		(0, _remove2['default'])('wow').subscribe(function () {});
+		(0, _remove2.default)('wow').subscribe(function () {});
 
@@ -38,3 +39,3 @@ expect(backend.write).toHaveBeenCalled();
 	it('should make a request with parameters', function () {
-		(0, _remove2['default'])('users', {
+		(0, _remove2.default)('users', {
 			parameters: {
@@ -60,3 +61,3 @@ users: 1234
 	it('should make a request with custom headers', function () {
-		(0, _remove2['default'])('users', {
+		(0, _remove2.default)('users', {
 			parameters: {
@@ -86,3 +87,3 @@ users: 1234
 	it('should make a request with nested resource', function () {
-		(0, _remove2['default'])('users.posts.comments', {
+		(0, _remove2.default)('users.posts.comments', {
 			parameters: {
@@ -113,6 +114,6 @@ users: 1234,
 		expect(function () {
-			(0, _remove2['default'])('').subscribe(function () {});
+			(0, _remove2.default)('').subscribe(function () {});
 		}).toThrow();
 		expect(function () {
-			(0, _remove2['default'])('').subscribe(function () {});
+			(0, _remove2.default)('').subscribe(function () {});
 		}).toThrowError('Invalid config');
@@ -123,8 +124,8 @@ });
 		expect(function () {
-			(0, _remove2['default'])('users.comments').subscribe(function () {});
+			(0, _remove2.default)('users.comments').subscribe(function () {});
 		}).toThrow();
 		expect(function () {
-			(0, _remove2['default'])('users.comments').subscribe(function () {});
+			(0, _remove2.default)('users.comments').subscribe(function () {});
 		}).toThrowError('Invalid params: param is required for resource users');
 	});
 });

lib/request.js

 'use strict';
 
-Object.defineProperty(exports, '__esModule', {
+var _extends = Object.assign || function (target) { for (var i = 1; i < arguments.length; i++) { var source = arguments[i]; for (var key in source) { if (Object.prototype.hasOwnProperty.call(source, key)) { target[key] = source[key]; } } } return target; };
+
+Object.defineProperty(exports, "__esModule", {
 	value: true
 });
-
-var _extends = Object.assign || function (target) { for (var i = 1; i < arguments.length; i++) { var source = arguments[i]; for (var key in source) { if (Object.prototype.hasOwnProperty.call(source, key)) { target[key] = source[key]; } } } return target; };
-
 exports.setBackend = setBackend;
 exports.onNotification = onNotification;
 exports.use = use;
-exports['default'] = makeRequest;
+exports.default = makeRequest;
 
@@ -49,3 +48,3 @@ var _rx = require('rx');
 
-	middleware.onNext({
+	middleware.observer.onNext({
 		res: response,
@@ -52,0 +51,0 @@ rawMessage: rawMessage,

lib/request.spec.js

 'use strict';
 
-function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { 'default': obj }; }
-
 var _request = require('./request');
@@ -15,2 +13,7 @@
 
+function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
+
+function _typeof(obj) { return obj && typeof Symbol !== "undefined" && obj.constructor === Symbol ? "symbol" : typeof obj; }
+
+/* istanbul ignore next */
 describe('request', function () {
@@ -33,5 +36,5 @@
 
-			var observable = (0, _request2['default'])({ resource: 'test', method: 'get' });
+			var observable = (0, _request2.default)({ resource: 'test', method: 'get' });
 			expect(observable).toBeDefined();
-			expect(observable['catch']).toBeDefined();
+			expect(observable.catch).toBeDefined();
 			expect(observable.forEach).toBeDefined();
@@ -69,3 +72,3 @@ expect(observable.map).toBeDefined();
 
-			(0, _rxws2['default'])({
+			(0, _rxws2.default)({
 				method: 'get',
@@ -77,3 +80,3 @@ resource: 'users'
 			expect(request.header.correlationId).toBeDefined();
-			expect(typeof request.header.correlationId).toBe('string');
+			expect(_typeof(request.header.correlationId)).toBe('string');
 		});
@@ -91,3 +94,3 @@
 
-			(0, _rxws2['default'])({
+			(0, _rxws2.default)({
 				method: 'get',
@@ -111,3 +114,3 @@ resource: 'users'
 
-			(0, _rxws2['default'])({
+			(0, _rxws2.default)({
 				method: 'eval',
@@ -135,3 +138,3 @@ resource: 'users'
 
-			(0, _rxws2['default'])({
+			(0, _rxws2.default)({
 				method: 'get',
@@ -155,3 +158,3 @@ resource: 'users',
 
-			(0, _rxws2['default'])({
+			(0, _rxws2.default)({
 				method: 'get',
@@ -175,3 +178,3 @@ resource: 'users'
 
-			(0, _rxws2['default'])({
+			(0, _rxws2.default)({
 				method: 'get',
@@ -213,3 +216,3 @@ resource: 'users'
 
-			(0, _rxws2['default'])({
+			(0, _rxws2.default)({
 				method: 'get',
@@ -241,3 +244,3 @@ resource: 'users'
 
-			(0, _rxws2['default'])({
+			(0, _rxws2.default)({
 				method: 'get',
@@ -269,3 +272,3 @@ resource: 'users'
 
-			(0, _rxws2['default'])({
+			(0, _rxws2.default)({
 				method: 'get',
@@ -297,3 +300,3 @@ resource: 'users'
 
-			(0, _rxws2['default'])({
+			(0, _rxws2.default)({
 				method: 'get',
@@ -330,3 +333,3 @@ resource: 'users'
 
-			_rxws2['default'].onNotification('farrot').subscribe(function (body, headers) {
+			_rxws2.default.onNotification('farrot').subscribe(function (body, headers) {
 				expect(body.eventData.test).toBe(5);
@@ -355,3 +358,3 @@ run();
 
-			_rxws2['default'].onNotification('farrot').subscribe(function (body, headers) {});
+			_rxws2.default.onNotification('farrot').subscribe(function (body, headers) {});
 
@@ -407,3 +410,3 @@ backend.mockServerMessage(JSON.stringify({
 
-			_rxws2['default'].use().subscribe(transformers.response);
+			_rxws2.default.use().subscribe(transformers.response);
 
@@ -474,6 +477,6 @@ backend.mockServerMessage(JSON.stringify({
 
-			_rxws2['default'].use().subscribe(transformers.response1);
-			_rxws2['default'].use().subscribe(transformers.response2);
-			_rxws2['default'].use().subscribe(transformers.response3);
-			_rxws2['default'].use().subscribe(transformers.response4);
+			_rxws2.default.use().subscribe(transformers.response1);
+			_rxws2.default.use().subscribe(transformers.response2);
+			_rxws2.default.use().subscribe(transformers.response3);
+			_rxws2.default.use().subscribe(transformers.response4);
 
@@ -547,6 +550,6 @@ backend.mockServerMessage(JSON.stringify({
 
-			_rxws2['default'].use().subscribe(transformers.response1);
-			_rxws2['default'].use().subscribe(transformers.response2);
-			_rxws2['default'].use().subscribe(transformers.response3);
-			_rxws2['default'].use().subscribe(transformers.response4);
+			_rxws2.default.use().subscribe(transformers.response1);
+			_rxws2.default.use().subscribe(transformers.response2);
+			_rxws2.default.use().subscribe(transformers.response3);
+			_rxws2.default.use().subscribe(transformers.response4);
 
@@ -590,5 +593,5 @@ backend.mockServerMessage(JSON.stringify({
 
-			_rxws2['default'].use().subscribe(transformers.response);
+			_rxws2.default.use().subscribe(transformers.response);
 
-			(0, _rxws2['default'])({
+			(0, _rxws2.default)({
 				method: 'get',
@@ -595,0 +598,0 @@ resource: 'users'

lib/rxws.js

 'use strict';
 
-Object.defineProperty(exports, '__esModule', {
+Object.defineProperty(exports, "__esModule", {
   value: true
 });
 
-function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { 'default': obj }; }
-
 var _remove = require('./remove');
@@ -37,14 +35,15 @@
 
-_request2['default'].remove = _remove2['default'];
-_request2['default'].get = _get2['default'];
-_request2['default'].put = _put2['default'];
-_request2['default'].post = _post2['default'];
-_request2['default'].patch = _patch2['default'];
-_request2['default'].head = _head2['default'];
-_request2['default'].setBackend = _request.setBackend;
+function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
 
-_request2['default'].onNotification = _request.onNotification;
-_request2['default'].use = _request.use;
+_request2.default.remove = _remove2.default;
+_request2.default.get = _get2.default;
+_request2.default.put = _put2.default;
+_request2.default.post = _post2.default;
+_request2.default.patch = _patch2.default;
+_request2.default.head = _head2.default;
+_request2.default.setBackend = _request.setBackend;
 
-exports['default'] = _request2['default'];
-module.exports = exports['default'];
+_request2.default.onNotification = _request.onNotification;
+_request2.default.use = _request.use;
+
+exports.default = _request2.default;

lib/SockJSBackend.js

 'use strict';
 
-Object.defineProperty(exports, '__esModule', {
+Object.defineProperty(exports, "__esModule", {
 	value: true
 });
 
-function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { 'default': obj }; }
-
 var _rx = require('rx');
@@ -15,2 +13,4 @@
 
+function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
+
 var sock = undefined;
@@ -25,3 +25,3 @@
 function tryConnect(url, observer) {
-	sock = new _sockjsClient2['default'](url);
+	sock = new _sockjsClient2.default(url);
 
@@ -42,3 +42,3 @@ sock.onopen = function () {
 			}
-		})['catch'](function () {
+		}).catch(function () {
 			observer.onError('Lost connection');
@@ -53,4 +53,3 @@ });
 
-exports['default'] = {
-
+exports.default = {
 	connect: function connect(url, forceFail) {
@@ -61,7 +60,5 @@ return _rx.Observable.create(function (observer) {
 	},
-
 	write: function write(request) {
 		sock.send(request);
 	},
-
 	onMessage: function onMessage(callback) {
@@ -72,7 +69,5 @@ sock.onmessage = function (message) {
 	},
-
 	close: function close() {
 		sock.close();
 	}
-};
-module.exports = exports['default'];
+};

lib/test-utils.js

 'use strict';
 
-Object.defineProperty(exports, '__esModule', {
+Object.defineProperty(exports, "__esModule", {
 	value: true
@@ -13,2 +13,3 @@ });
 
+/* istanbul ignore next */
 function makeMockBackend() {
@@ -24,11 +25,7 @@ var callback = undefined;
 		},
-
 		write: function write(request) {},
-
 		onMessage: function onMessage(_callback) {
 			callback = _callback;
 		},
-
 		close: function close() {},
-
 		mockServerMessage: function mockServerMessage(message) {
@@ -47,2 +44,3 @@ callback(message);
 
+/* istanbul ignore next */
 function messagesAreEqual(actual, expected, preserveCorrelation) {
@@ -49,0 +47,0 @@ actual = (0, _lodash.cloneDeep)(actual);

lib/utils.js

 'use strict';
 
-Object.defineProperty(exports, '__esModule', {
+var _extends = Object.assign || function (target) { for (var i = 1; i < arguments.length; i++) { var source = arguments[i]; for (var key in source) { if (Object.prototype.hasOwnProperty.call(source, key)) { target[key] = source[key]; } } } return target; };
+
+Object.defineProperty(exports, "__esModule", {
 	value: true
 });
-
-var _extends = Object.assign || function (target) { for (var i = 1; i < arguments.length; i++) { var source = arguments[i]; for (var key in source) { if (Object.prototype.hasOwnProperty.call(source, key)) { target[key] = source[key]; } } } return target; };
-
 exports.getRetryTimer = getRetryTimer;
 exports.generateRequestObject = generateRequestObject;
 
-function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { 'default': obj }; }
-
-function _defineProperty(obj, key, value) { if (key in obj) { Object.defineProperty(obj, key, { value: value, enumerable: true, configurable: true, writable: true }); } else { obj[key] = value; } return obj; }
-
 var _nodeUuid = require('node-uuid');
@@ -20,2 +15,6 @@
 
+function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
+
+function _defineProperty(obj, key, value) { if (key in obj) { Object.defineProperty(obj, key, { value: value, enumerable: true, configurable: true, writable: true }); } else { obj[key] = value; } return obj; }
+
 function sanitizeParams(resource, params) {
@@ -43,3 +42,2 @@ var resourceElements = resource.split('.');
  */
-
 function generateRequestObject(defaultHeaders) {
@@ -56,3 +54,3 @@ return function (config) {
 
-		var correlationId = (0, _nodeUuid2['default'])();
+		var correlationId = (0, _nodeUuid2.default)();
 		var resourceList = config.resource.split('.');
@@ -59,0 +57,0 @@

lib/utils.spec.js

@@ -5,2 +5,3 @@ 'use strict';
 
+/* istanbul ignore next */
 describe('utils', function () {
@@ -7,0 +8,0 @@ describe('generateRequestObject', function () {

package.json

 {
   "name": "rxws",
-  "version": "3.0.0",
+  "version": "3.0.1",
   "description": "A RESTful reactive JavaScript implmentation on top of web sockets",
@@ -8,7 +8,8 @@ "main": "lib/rxws.js",
     "test": "node node_modules/jasmine/bin/jasmine.js",
-    "build": "node node_modules/babel/bin/babel.js src --out-dir lib",
+    "build": "babel src --out-dir lib",
     "clean": "rm -rf lib",
     "test-watch": "node node_modules/jasmine-node/bin/jasmine-node --autoTest lib",
     "watch": "node node_modules/babel/bin/babel.js src --out-dir lib --watch",
-    "copy": "cp -r lib ~/dev/sme-frontend/jspm_packages/npm/rxws@1.0.10/"
+    "copy": "cp -r lib ~/dev/sme-frontend/jspm_packages/npm/rxws@1.0.10/",
+    "coverage": "babel-node node_modules/isparta/bin/isparta cover --report text --report html node_modules/jasmine/bin/jasmine.js"
   },
@@ -26,7 +27,12 @@ "repository": {
   "devDependencies": {
-    "babel": "^5.8.21",
-    "babel-core": "^5.8.24",
-    "babel-loader": "^5.3.2",
+    "babel": "6.3.13",
+    "babel-cli": "6.3.17",
+    "babel-core": "6.3.17",
+    "babel-loader": "^6.2.0",
+    "babel-preset-es2015": "6.3.13",
+    "babel-preset-stage-0": "6.3.13",
+    "babel-register": "6.3.13",
     "file-loader": "^0.8.4",
     "html-loader": "^0.3.0",
+    "isparta": "4.0.0",
     "jasmine": "^2.3.2",
@@ -51,7 +57,7 @@ "jasmine-core": "^2.3.4",
   },
-	"files": [
-		"dist",
-		"src",
-		"lib"
-	]
+  "files": [
+    "dist",
+    "src",
+    "lib"
+  ]
 }

README.md

 # RxWS
-A RESTful Reactive JavaScript Implementation on top of Web Sockets. This includes,
-`GET`, `POST`, `PUT`, `REMOVE` (DELETE), `PATCH`, and `HEAD`. RxWS gaurantees message delivery by generating
+Status: [![Build Status](https://travis-ci.org/CanopyTax/rxws.svg?branch=master)](https://travis-ci.org/CanopyTax/rxws) [![codecov.io](https://codecov.io/github/CanopyTax/rxws/coverage.svg?branch=master)](https://codecov.io/github/CanopyTax/rxws?branch=master)
+
+RxWS is a RESTful reactive JavaScript implementation on top of web sockets. This includes,
+`GET`, `POST`, `PUT`, `REMOVE` (DELETE), `PATCH`, and `HEAD`. RxWS guarantees message delivery by generating
 a correlation id for each message (to and from the server). Both the server and client automatically send an
@@ -5,0 +7,0 @@ acknowledgement response for each request. If there is no acknowledgement after a timeout, an error is thrown.

src/get.spec.js

@@ -5,2 +5,3 @@ import get from './get';
 
+/* istanbul ignore next */
 describe('GET', () => {
@@ -7,0 +8,0 @@ let backend;

src/head.spec.js

@@ -5,2 +5,3 @@ import head from './head';
 
+/* istanbul ignore next */
 describe('HEAD', () => {
@@ -7,0 +8,0 @@ let backend;

src/patch.spec.js

@@ -5,2 +5,3 @@ import patch from './patch';
 
+/* istanbul ignore next */
 describe('patch', () => {
@@ -7,0 +8,0 @@ let backend;

src/post.spec.js

@@ -5,2 +5,3 @@ import post from './post';
 
+/* istanbul ignore next */
 describe('POST', () => {
@@ -7,0 +8,0 @@ let backend;

src/put.spec.js

@@ -5,2 +5,3 @@ import put from './put';
 
+/* istanbul ignore next */
 describe('put', () => {
@@ -7,0 +8,0 @@ let backend;

src/remove.spec.js

@@ -5,2 +5,3 @@ import remove from './remove';
 
+/* istanbul ignore next */
 describe('remove', () => {
@@ -7,0 +8,0 @@ let backend;

src/request.js

@@ -13,4 +13,6 @@ import { Observable } from 'rx';
 	{
-		onNext: ({res, reply}) => {
-			reply(res);
+		observer: {
+			onNext: ({res, reply}) => {
+				reply(res);
+			}
 		}
@@ -35,3 +37,3 @@ }
 
-	middleware.onNext({
+	middleware.observer.onNext({
 		res: response,
@@ -38,0 +40,0 @@ rawMessage: rawMessage,

src/request.spec.js

@@ -6,2 +6,3 @@ import makeRequest, { setBackend } from './request';
 
+/* istanbul ignore next */
 describe('request', () => {
@@ -8,0 +9,0 @@

src/test-utils.js

 import { Observable } from 'rx';
 import { isEqual, cloneDeep } from 'lodash';
 
+/* istanbul ignore next */
 export function makeMockBackend() {
@@ -38,2 +39,3 @@ let callback;
 
+/* istanbul ignore next */
 export function messagesAreEqual(actual, expected, preserveCorrelation) {
@@ -40,0 +42,0 @@ actual = cloneDeep(actual);

src/utils.spec.js

 import { generateRequestObject } from './utils';
 
+/* istanbul ignore next */
 describe('utils', () => {
@@ -4,0 +5,0 @@ describe('generateRequestObject', () => {

No alert changes

Improved metrics

Total package byte prevSize

100990

increased by0.57%

Lines of code

3167

increased by0.48%

Number of lines in readme file

186

increased by1.09%

Worsened metrics

Dev dependency count

23

increased by27.78%

No dependency changes