rsocket-tcp-server
Advanced tools
Comparing version 0.0.19 to 0.0.21
@@ -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; |
@@ -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); |
{ | ||
"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" | ||
} |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
New author
Supply chain riskA 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
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
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
18699
6
2
80
2
+ Addedcore-js@3.39.0(transitive)
+ Addedcross-fetch@3.1.8(transitive)
+ Addedfbjs@2.0.0(transitive)
+ Addednode-fetch@2.7.0(transitive)
+ Addedrsocket-core@0.0.21(transitive)
+ Addedrsocket-flowable@0.0.21(transitive)
+ Addedrsocket-tcp-client@0.0.21(transitive)
+ Addedrsocket-types@0.0.21(transitive)
+ Addedtr46@0.0.3(transitive)
+ Addedwebidl-conversions@3.0.1(transitive)
+ Addedwhatwg-url@5.0.0(transitive)
- Removedbase64-js@1.5.1(transitive)
- Removedbuffer@5.7.1(transitive)
- Removedcore-js@2.6.12(transitive)
- Removedencoding@0.1.13(transitive)
- Removedfbjs@1.0.0(transitive)
- Removediconv-lite@0.6.3(transitive)
- Removedieee754@1.2.1(transitive)
- Removedis-stream@1.1.0(transitive)
- Removedisomorphic-fetch@2.2.1(transitive)
- Removednode-fetch@1.7.3(transitive)
- Removedrsocket-core@0.0.19(transitive)
- Removedrsocket-flowable@0.0.14(transitive)
- Removedrsocket-tcp-client@0.0.19(transitive)
- Removedrsocket-types@0.0.16(transitive)
- Removedsafer-buffer@2.1.2(transitive)
- Removedwhatwg-fetch@3.6.20(transitive)
Updatedfbjs@^2.0.0
Updatedrsocket-core@^0.0.21
Updatedrsocket-flowable@^0.0.21
Updatedrsocket-tcp-client@^0.0.21
Updatedrsocket-types@^0.0.21