rsocket-tcp-server - npm Package Compare versions

Comparing version 0.0.19 to 0.0.21

build/index.js

@@ -15,3 +15,3 @@ /** Copyright (c) Facebook, Inc. and its affiliates.
  *
- * 
+ *
  */
@@ -21,8 +21,9 @@
 Object.defineProperty(exports, '__esModule', {value: true});
+exports.default = void 0;
 
-var _RSocketTCPServer = require('./RSocketTCPServer');
-var _RSocketTCPServer2 = _interopRequireDefault(_RSocketTCPServer);
+var _RSocketTCPServer = _interopRequireDefault(require('./RSocketTCPServer'));
 function _interopRequireDefault(obj) {
   return obj && obj.__esModule ? obj : {default: obj};
 }
-exports.default = _RSocketTCPServer2.default;
+var _default = _RSocketTCPServer.default;
+exports.default = _default;

build/RSocketTCPServer.js

@@ -15,3 +15,3 @@ /** Copyright (c) Facebook, Inc. and its affiliates.
  *
- * 
+ *
  */
@@ -21,9 +21,8 @@
 Object.defineProperty(exports, '__esModule', {value: true});
+exports.default = void 0;
 
 var _rsocketTcpClient = require('rsocket-tcp-client');
 
-var _events = require('events');
-var _events2 = _interopRequireDefault(_events);
-var _net = require('net');
-var _net2 = _interopRequireDefault(_net);
+var _events = _interopRequireDefault(require('events'));
+var _net = _interopRequireDefault(require('net'));
 var _rsocketFlowable = require('rsocket-flowable');
@@ -35,7 +34,7 @@ function _interopRequireDefault(obj) {
 /**
-                                                                                                                                                  * A TCP transport server.
-                                                                                                                                                  */
+ * A TCP transport server.
+ */
 class RSocketTCPServer {
   constructor(options, encoders) {
-    this._emitter = new _events2.default();
+    this._emitter = new _events.default();
     this._encoders = encoders;
@@ -46,3 +45,3 @@ this._options = options;
   start() {
-    return new _rsocketFlowable.Flowable(subscriber => {
+    return new _rsocketFlowable.Flowable((subscriber) => {
       let server;
@@ -55,4 +54,4 @@ const onClose = () => {
       };
-      const onError = error => subscriber.onError(error);
-      const onConnection = socket => {
+      const onError = (error) => subscriber.onError(error);
+      const onConnection = (socket) => {
         subscriber.onNext(
@@ -73,6 +72,6 @@ new _rsocketTcpClient.RSocketTcpConnection(socket, this._encoders)
         },
-        request: n => {
+        request: (n) => {
           if (!server) {
-            const factory = this._options.serverFactory ||
-              _net2.default.createServer;
+            const factory =
+              this._options.serverFactory || _net.default.createServer;
             server = factory(onConnection);
@@ -79,0 +78,0 @@ server.listen(this._options.port, this._options.host);

package.json

 {
   "name": "rsocket-tcp-server",
   "description": "RSocket TCP server",
-  "version": "0.0.19",
+  "version": "0.0.21",
   "repository": {
@@ -12,8 +12,9 @@ "type": "git",
   "dependencies": {
-    "fbjs": "^1.0.0",
-    "rsocket-core": "^0.0.19",
-    "rsocket-flowable": "^0.0.14",
-    "rsocket-tcp-client": "^0.0.19",
-    "rsocket-types": "^0.0.16"
-  }
+    "fbjs": "^2.0.0",
+    "rsocket-core": "^0.0.21",
+    "rsocket-flowable": "^0.0.21",
+    "rsocket-tcp-client": "^0.0.21",
+    "rsocket-types": "^0.0.21"
+  },
+  "gitHead": "c10250d8bf2904101ebc61ea15f85e493cf005f1"
 }

New alerts

New author

Supply chain risk

A new npm collaborator published a version of the package for the first time. New collaborators are usually benign additions to a project, but do indicate a change to the security surface area of a package.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

18699

145.55%

Number of package files

6

20%

Worsened metrics

Number of medium supply chain risk alerts

2

100%

Dependency changes

• + Added

  core-js@3.44.0
  (transitive)

• + Added

  cross-fetch@3.2.0
  (transitive)

• + Added

  fbjs@2.0.0
  (transitive)

• + Added

  node-fetch@2.7.0
  (transitive)

• + Added

  rsocket-core@0.0.21
  (transitive)

• + Added

  rsocket-flowable@0.0.21
  (transitive)

• + Added

  rsocket-tcp-client@0.0.21
  (transitive)

• + Added

  rsocket-types@0.0.21
  (transitive)

• + Added

  tr46@0.0.3
  (transitive)

• + Added

  webidl-conversions@3.0.1
  (transitive)

• + Added

  whatwg-url@5.0.0
  (transitive)

• - Removed

  base64-js@1.5.1
  (transitive)

• - Removed

  buffer@5.7.1
  (transitive)

• - Removed

  core-js@2.6.12
  (transitive)

• - Removed

  encoding@0.1.13
  (transitive)

• - Removed

  fbjs@1.0.0
  (transitive)

• - Removed

  iconv-lite@0.6.3
  (transitive)

• - Removed

  ieee754@1.2.1
  (transitive)

• - Removed

  is-stream@1.1.0
  (transitive)

• - Removed

  isomorphic-fetch@2.2.1
  (transitive)

• - Removed

  node-fetch@1.7.3
  (transitive)

• - Removed

  rsocket-core@0.0.19
  (transitive)

• - Removed

  rsocket-flowable@0.0.14
  (transitive)

• - Removed

  rsocket-tcp-client@0.0.19
  (transitive)

• - Removed

  rsocket-types@0.0.16
  (transitive)

• - Removed

  safer-buffer@2.1.2
  (transitive)

• - Removed

  whatwg-fetch@3.6.20
  (transitive)

• Updated

  fbjs@^2.0.0

• Updated

  rsocket-core@^0.0.21

• Updated

  rsocket-flowable@^0.0.21

• Updated

  rsocket-tcp-client@^0.0.21

• Updated

  rsocket-types@^0.0.21