Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More
Socket
Sign inDemoInstall
Socket

rsocket-tcp-server

Package Overview
Dependencies
Maintainers
3
Versions
30
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

rsocket-tcp-server - npm Package Compare versions

Comparing version 0.0.19 to 0.0.21

LICENSE

9

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;

@@ -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"
}
SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc