node-multi-socketservers
Advanced tools
Comparing version 0.2.3 to 0.2.4
@@ -26,16 +26,29 @@ "use strict"; | ||
this.servers.forEach((server, i) => { | ||
this.servers[i].sockets = null; | ||
}); | ||
// web server init | ||
return super.listen(requestListener).then(() => { | ||
this.servers.forEach((server, i) => { | ||
this.servers[i].sockets = io(server.server); | ||
}); | ||
// socket server init | ||
return new Promise((resolve) => { | ||
if (0 < this._tmpOnConnection.length) { | ||
this.servers.forEach((server, i) => { | ||
this._tmpOnConnection.forEach((tmpOnConnection) => { | ||
this.connection(tmpOnConnection); | ||
this.servers[i].sockets = null; | ||
this.servers[i].sockets = io(server.server); | ||
if (0 < this._tmpOnConnection.length) { | ||
let _tmpOnConnection = this._tmpOnConnection.slice(); | ||
server.sockets.on("connection", (socket) => { | ||
_tmpOnConnection.forEach((tmpOnConnection) => { | ||
new Promise(() => { | ||
tmpOnConnection(socket, server); | ||
}); | ||
}); | ||
}); | ||
} | ||
}); | ||
@@ -45,8 +58,10 @@ | ||
} | ||
resolve(); | ||
return Promise.resolve(); | ||
}); | ||
}).catch((err) => { | ||
(0, console).log(err); | ||
}); | ||
} | ||
@@ -77,14 +92,4 @@ | ||
if ("function" === typeof server.sockets.setMaxListeners) { | ||
server.sockets.setMaxListeners(0); | ||
} | ||
server.sockets.on("connection", (socket) => { | ||
if ("function" === typeof socket.setMaxListeners) { | ||
socket.setMaxListeners(0); | ||
} | ||
eventListener(socket, server); | ||
}); | ||
@@ -91,0 +96,0 @@ |
{ | ||
"name": "node-multi-socketservers", | ||
"version": "0.2.3", | ||
"version": "0.2.4", | ||
"description": "A multi http & socket servers manager, based on node-multi-webserver", | ||
@@ -5,0 +5,0 @@ "main": "lib/main.js", |
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
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
22351
555