Comparing version 1.0.1 to 1.0.2
@@ -11,4 +11,4 @@ const io = require('socket.io-client'); | ||
const CThread = function(socket, options) { | ||
eventm.create("cthread_msg", null, { keepSession: false }); | ||
eventm.create("cthread_disconnect", null, { keepSession: false }); | ||
eventm.create("cthread_msg", { keepSession: false }); | ||
eventm.create("cthread_disconnect", { keepSession: false }); | ||
@@ -117,5 +117,5 @@ this.getPid = () => process.pid; | ||
const connection = eventm.create("connection", null, { promise: true }); | ||
const connection = eventm.create("connection"); | ||
initConnection(); | ||
return connection; | ||
return connection.getPromise(); | ||
} | ||
@@ -122,0 +122,0 @@ |
@@ -156,37 +156,9 @@ const processExists = require("process-exists"); | ||
const guuid = uuidv4(); | ||
eventm.create( | ||
`thread_${guuid}`, | ||
null, | ||
{ promise: true } | ||
); | ||
eventm.create( | ||
`thread_${guuid}_msg`, | ||
null, | ||
{ keepSession: false, promise: true } | ||
); | ||
eventm.create( | ||
`thread_${guuid}_disconnect`, | ||
null, | ||
{ keepSession: false } | ||
); | ||
eventm.create( | ||
`thread_${guuid}_process_stdout`, | ||
null, | ||
{ keepSession: false } | ||
); | ||
eventm.create( | ||
`thread_${guuid}_process_stderr`, | ||
null, | ||
{ keepSession: false } | ||
); | ||
eventm.create( | ||
`thread_${guuid}_process_exit`, | ||
null, | ||
{ keepSession: false } | ||
); | ||
eventm.create( | ||
`thread_${guuid}_process_close`, | ||
null, | ||
{ keepSession: false } | ||
); | ||
eventm.create(`thread_${guuid}`); | ||
eventm.create(`thread_${guuid}_msg`, { keepSession: false }); | ||
eventm.create(`thread_${guuid}_disconnect`, { keepSession: false }); | ||
eventm.create(`thread_${guuid}_process_stdout`, { keepSession: false }); | ||
eventm.create(`thread_${guuid}_process_stderr`, { keepSession: false }); | ||
eventm.create(`thread_${guuid}_process_exit`, { keepSession: false }); | ||
eventm.create(`thread_${guuid}_process_close`, { keepSession: false }); | ||
return guuid; | ||
@@ -196,3 +168,3 @@ }; | ||
const Nthread = function(server, socket, options) { | ||
eventm.create(`thread_msg`, null, { keepSession: false, promise: true }); | ||
eventm.create(`thread_msg`, { keepSession: false }); | ||
@@ -343,3 +315,3 @@ const listThreads = []; | ||
const listen = eventm.create("listen", null, { promise: true }); | ||
const listen = eventm.create("listen"); | ||
@@ -349,5 +321,5 @@ this.server = await initServer(); | ||
return listen; | ||
return listen.getPromise(); | ||
}; | ||
module.exports = NThreadListen; |
{ | ||
"name": "nthread-js", | ||
"version": "1.0.1", | ||
"version": "1.0.2", | ||
"description": "Create easily threads in NodeJs", | ||
@@ -27,3 +27,3 @@ "main": "index.js", | ||
"dependencies": { | ||
"eventm": "1.2.1", | ||
"eventm": "1.3.0", | ||
"get-port": "^5.0.0", | ||
@@ -30,0 +30,0 @@ "process-exists": "^3.1.0", |
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
26296
440
+ Addedeventm@1.3.0(transitive)
- Removedeventm@1.2.1(transitive)
Updatedeventm@1.3.0