@akanass/rx-socket-client - npm Package Compare versions

Comparing version 1.1.0 to 1.2.0

commonjs/lib/rx-socket-client.subject.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+const buffer_1 = require("buffer");
 const rxjs_1 = require("rxjs");
-const webSocket_1 = require("rxjs/webSocket");
 const root_1 = require("rxjs/internal/util/root");
 const operators_1 = require("rxjs/operators");
+const webSocket_1 = require("rxjs/webSocket");
 const ws = require("websocket");
-const buffer_1 = require("buffer");
 /**
@@ -66,3 +66,3 @@ * Class definition
             openObserver: {
-                next: (e) => {
+                next: () => {
                     this._connectionStatus$.next(true);
@@ -72,3 +72,3 @@ }
             closeObserver: {
-                next: (e) => {
+                next: () => {
                     this._cleanSocket();
@@ -137,3 +137,5 @@ this._connectionStatus$.next(false);
         this._message$(event)
-            .subscribe((message) => cb(message.data), undefined, () => {
+            .subscribe((message) => cb(message.data), 
+        /* istanbul ignore next */
+        () => undefined, () => {
             /* istanbul ignore else */
@@ -182,4 +184,8 @@ if (event === 'close') {
     onClose$() {
-        return rxjs_1.Observable.create(observer => {
-            this.subscribe(undefined, undefined, () => {
+        return new rxjs_1.Observable(observer => {
+            this.subscribe(
+            /* istanbul ignore next */
+            () => undefined, 
+            /* istanbul ignore next */
+            () => undefined, () => {
                 observer.next();
@@ -263,3 +269,3 @@ observer.complete();
             this.next(m);
-        }, (error) => {
+        }, () => {
             /* istanbul ignore if */
@@ -280,3 +286,5 @@ if (!this._socket) {
             .pipe(operators_1.takeWhile((v, index) => index < this._reconnectAttempts && !this._socket));
-        this._reconnectionSubscription = this._reconnectionObservable.subscribe(() => this._connect(), undefined, () => {
+        this._reconnectionSubscription = this._reconnectionObservable.subscribe(() => this._connect(), 
+        /* istanbul ignore next */
+        () => undefined, () => {
             this._cleanReconnection();
@@ -283,0 +291,0 @@ if (!this._socket) {

esm2015/lib/rx-socket-client.subject.js

@@ -1,7 +0,7 @@
-import { Observable, Subject, interval } from 'rxjs';
+import { Buffer } from 'buffer';
+import { interval, Observable, Subject } from 'rxjs';
+import { root } from 'rxjs/internal/util/root';
+import { distinctUntilChanged, filter, map, takeWhile } from 'rxjs/operators';
 import { WebSocketSubject } from 'rxjs/webSocket';
-import { root } from 'rxjs/internal/util/root';
-import { distinctUntilChanged, takeWhile, map, filter } from 'rxjs/operators';
 import * as ws from 'websocket';
-import { Buffer } from 'buffer';
 /**
@@ -64,3 +64,3 @@ * Class definition
             openObserver: {
-                next: (e) => {
+                next: () => {
                     this._connectionStatus$.next(true);
@@ -70,3 +70,3 @@ }
             closeObserver: {
-                next: (e) => {
+                next: () => {
                     this._cleanSocket();
@@ -135,3 +135,5 @@ this._connectionStatus$.next(false);
         this._message$(event)
-            .subscribe((message) => cb(message.data), undefined, () => {
+            .subscribe((message) => cb(message.data), 
+        /* istanbul ignore next */
+        () => undefined, () => {
             /* istanbul ignore else */
@@ -180,4 +182,8 @@ if (event === 'close') {
     onClose$() {
-        return Observable.create(observer => {
-            this.subscribe(undefined, undefined, () => {
+        return new Observable(observer => {
+            this.subscribe(
+            /* istanbul ignore next */
+            () => undefined, 
+            /* istanbul ignore next */
+            () => undefined, () => {
                 observer.next();
@@ -261,3 +267,3 @@ observer.complete();
             this.next(m);
-        }, (error) => {
+        }, () => {
             /* istanbul ignore if */
@@ -278,3 +284,5 @@ if (!this._socket) {
             .pipe(takeWhile((v, index) => index < this._reconnectAttempts && !this._socket));
-        this._reconnectionSubscription = this._reconnectionObservable.subscribe(() => this._connect(), undefined, () => {
+        this._reconnectionSubscription = this._reconnectionObservable.subscribe(() => this._connect(), 
+        /* istanbul ignore next */
+        () => undefined, () => {
             this._cleanReconnection();
@@ -281,0 +289,0 @@ if (!this._socket) {

esm5/lib/rx-socket-client.subject.js

 "use strict";
 var __extends = (this && this.__extends) || (function () {
-    var extendStatics = Object.setPrototypeOf ||
-        ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||
-        function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; };
+    var extendStatics = function (d, b) {
+        extendStatics = Object.setPrototypeOf ||
+            ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||
+            function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; };
+        return extendStatics(d, b);
+    };
     return function (d, b) {
@@ -13,8 +16,8 @@ extendStatics(d, b);
 Object.defineProperty(exports, "__esModule", { value: true });
+var buffer_1 = require("buffer");
 var rxjs_1 = require("rxjs");
-var webSocket_1 = require("rxjs/webSocket");
 var root_1 = require("rxjs/internal/util/root");
 var operators_1 = require("rxjs/operators");
+var webSocket_1 = require("rxjs/webSocket");
 var ws = require("websocket");
-var buffer_1 = require("buffer");
 /**
@@ -78,3 +81,3 @@ * Class definition
             openObserver: {
-                next: function (e) {
+                next: function () {
                     _this._connectionStatus$.next(true);
@@ -84,3 +87,3 @@ }
             closeObserver: {
-                next: function (e) {
+                next: function () {
                     _this._cleanSocket();
@@ -154,3 +157,5 @@ _this._connectionStatus$.next(false);
         this._message$(event)
-            .subscribe(function (message) { return cb(message.data); }, undefined, function () {
+            .subscribe(function (message) { return cb(message.data); }, 
+        /* istanbul ignore next */
+        function () { return undefined; }, function () {
             /* istanbul ignore else */
@@ -200,4 +205,8 @@ if (event === 'close') {
         var _this = this;
-        return rxjs_1.Observable.create(function (observer) {
-            _this.subscribe(undefined, undefined, function () {
+        return new rxjs_1.Observable(function (observer) {
+            _this.subscribe(
+            /* istanbul ignore next */
+            function () { return undefined; }, 
+            /* istanbul ignore next */
+            function () { return undefined; }, function () {
                 observer.next();
@@ -288,3 +297,3 @@ observer.complete();
             _this.next(m);
-        }, function (error) {
+        }, function () {
             /* istanbul ignore if */
@@ -306,3 +315,5 @@ if (!_this._socket) {
             .pipe(operators_1.takeWhile(function (v, index) { return index < _this._reconnectAttempts && !_this._socket; }));
-        this._reconnectionSubscription = this._reconnectionObservable.subscribe(function () { return _this._connect(); }, undefined, function () {
+        this._reconnectionSubscription = this._reconnectionObservable.subscribe(function () { return _this._connect(); }, 
+        /* istanbul ignore next */
+        function () { return undefined; }, function () {
             _this._cleanReconnection();
@@ -309,0 +320,0 @@ if (!_this._socket) {

lib/rx-socket-client.subject.d.ts

@@ -150,3 +150,3 @@ /// <reference types="node" />
      */
-    private _message$<WebSocketMessageServer>(event);
+    private _message$;
     /**
@@ -157,3 +157,3 @@ * Function to clean socket data
      */
-    private _cleanSocket();
+    private _cleanSocket;
     /**
@@ -164,3 +164,3 @@ * Function to clean reconnection data
      */
-    private _cleanReconnection();
+    private _cleanReconnection;
     /**
@@ -171,3 +171,3 @@ * Function to create socket and subscribe to it
      */
-    private _connect();
+    private _connect;
     /**
@@ -178,3 +178,3 @@ * Function to reconnect socket
      */
-    private _reconnect();
+    private _reconnect;
     /**
@@ -188,3 +188,3 @@ * Default deserializer
      */
-    private _deserializer(e);
+    private _deserializer;
     /**
@@ -198,3 +198,3 @@ * Default serializer
      */
-    private _serializer(data);
+    private _serializer;
 }

LICENSE.md

 The MIT License (MIT)
 ====
 
-**Copyright (c) 2018 [Nicolas Jessel](https://github.com/njl07)**
+**Copyright (c) 2019 [Nicolas Jessel](https://github.com/njl07)**
 
@@ -6,0 +6,0 @@ Permission is hereby granted, free of charge, to any person obtaining a copy

package.json

@@ -1,1 +0,1 @@
-{"name":"@akanass/rx-socket-client","version":"1.1.0","description":"Reconnectable websocket client with RxJS Subject","main":"commonjs/index.js","module":"esm5/index.js","es2015":"esm2015/index.js","types":"index.d.ts","private":false,"repository":{"type":"git","url":"git+ssh://[e-mail]:njl07/rx-socket-client.git"},"keywords":["RxJS","Rx","ReactiveX","Observable","Observer","Subject","Socket","WebSocket","Streams","Async","ES2015","ES2016","ES2017","ES6","ES7","ES8","Typescript","Browser"],"contributors":[{"name":"Nicolas Jessel","url":"https://github.com/njl07"}],"license":"SEE LICENSE IN https://github.com/njl07/rx-socket-client/blob/master/LICENSE.md","bugs":{"url":"https://github.com/njl07/rx-socket-client/issues"},"homepage":"https://github.com/njl07/rx-socket-client#readme","dependencies":{"@types/node":"^10.1.4","websocket":"^1.0.26"},"peerDependencies":{"rxjs":"^6.2.0"},"engines":{"node":">=7.0.0"}}
+{"name":"@akanass/rx-socket-client","version":"1.2.0","description":"Reconnectable websocket client with RxJS Subject","main":"commonjs/index.js","module":"esm5/index.js","es2015":"esm2015/index.js","types":"index.d.ts","private":false,"repository":{"type":"git","url":"git+ssh://[e-mail]:akanass/rx-socket-client.git"},"keywords":["RxJS","Rx","ReactiveX","Observable","Observer","Subject","Socket","WebSocket","Streams","Async","ES2015","ES2016","ES2017","ES6","ES7","ES8","Typescript","Browser"],"contributors":[{"name":"Nicolas Jessel","url":"https://github.com/akanass"}],"license":"SEE LICENSE IN https://github.com/akanass/rx-socket-client/blob/master/LICENSE.md","bugs":{"url":"https://github.com/akanass/rx-socket-client/issues"},"homepage":"https://github.com/akanass/rx-socket-client#readme","dependencies":{"@types/node":"^12.6.8","websocket":"^1.0.29"},"peerDependencies":{"rxjs":"^6.5.2"},"engines":{"node":">=7.0.0"}}

README.md

@@ -5,13 +5,13 @@ # Rx-Socket-Client
 <div style="float:left;line-height:60px">
-    <a href="https://travis-ci.org/njl07/rx-socket-client.svg?branch=master">
-        <img src="https://travis-ci.org/njl07/rx-socket-client.svg?branch=master" alt="build" />
+    <a href="https://travis-ci.org/akanass/rx-socket-client.svg?branch=master">
+        <img src="https://travis-ci.org/akanass/rx-socket-client.svg?branch=master" alt="build" />
     </a>
-    <a href="https://coveralls.io/github/njl07/rx-socket-client?branch=master">
-        <img src="https://coveralls.io/repos/github/njl07/rx-socket-client/badge.svg?branch=master" alt="coveralls" />
+    <a href="https://coveralls.io/github/akanass/rx-socket-client?branch=master">
+        <img src="https://coveralls.io/repos/github/akanass/rx-socket-client/badge.svg?branch=master" alt="coveralls" />
     </a>
-    <a href="https://david-dm.org/njl07/rx-socket-client">
-        <img src="https://david-dm.org/njl07/rx-socket-client.svg" alt="dependencies" />
+    <a href="https://david-dm.org/akanass/rx-socket-client">
+        <img src="https://david-dm.org/akanass/rx-socket-client.svg" alt="dependencies" />
     </a>
-    <a href="https://david-dm.org/njl07/rx-socket-client?type=dev">
-        <img src="https://david-dm.org/njl07/rx-socket-client/dev-status.svg" alt="devDependencies" />
+    <a href="https://david-dm.org/akanass/rx-socket-client?type=dev">
+        <img src="https://david-dm.org/akanass/rx-socket-client/dev-status.svg" alt="devDependencies" />
     </a>
@@ -346,2 +346,6 @@ </div>
 
+* v1.2.0 (2019-07-18)
+    * Upgrade all packages' versions
+    * Migrate tests to [jest](https://jestjs.io/en/) and [ts-jest](https://kulshekhar.github.io/ts-jest/)
+    * Documentation
 * v1.1.0 (2018-05-31)
@@ -357,4 +361,4 @@ * Delete `error` process/methods because never called with reconnection
 
-Copyright (c) 2018 **Nicolas Jessel** Licensed under the [MIT license](https://github.com/njl07/rx-socket-client/tree/master/LICENSE.md).
+Copyright (c) 2018 **Nicolas Jessel** Licensed under the [MIT license](https://github.com/akanass/rx-socket-client/tree/master/LICENSE.md).
 
-[Back to top](#table-of-contents)
+[Back to top](#table-of-contents)

New alerts

Unidentified License

License

(Experimental) Something that seems like a license was found, but its contents could not be matched with a known license.

Found 1 instance in 1 package

Fixed alerts

Unidentified License

License

(Experimental) Something that seems like a license was found, but its contents could not be matched with a known license.

Found 1 instance in 1 package

Improved metrics

Number of lines in readme file

362

1.4%

Worsened metrics

Total package byte prevSize

1161803

-29.68%

Lines of code

13784

-27.65%

Dependency changes

• + Added

  @types/node@12.20.55
  (transitive)

• - Removed

  @types/node@10.17.60
  (transitive)

• Updated

  @types/node@^12.6.8

• Updated

  websocket@^1.0.29