| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
1 parent 153be6c commit 95219ea
1 file changed
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -248,19 +248,21 @@ cluster.disconnect = function(cb) { | |||
| 248 | 248 | intercom.once('disconnect', cb); | |
| 249 | 249 | }; | |
| 250 | 250 | ||
| 251 | + const methodMessageMapping = { | ||
| 252 | + close, | ||
| 253 | + exitedAfterDisconnect, | ||
| 254 | + listening, | ||
| 255 | + online, | ||
| 256 | + queryServer, | ||
| 257 | + }; | ||
| 258 | + | ||
| 251 | 259 | function onmessage(message, handle) { | |
| 252 | 260 | const worker = this; | |
| 253 | 261 | ||
| 254 | - if (message.act === 'online') | ||
| 255 | - online(worker); | ||
| 256 | - else if (message.act === 'queryServer') | ||
| 257 | - queryServer(worker, message); | ||
| 258 | - else if (message.act === 'listening') | ||
| 259 | - listening(worker, message); | ||
| 260 | - else if (message.act === 'exitedAfterDisconnect') | ||
| 261 | - exitedAfterDisconnect(worker, message); | ||
| 262 | - else if (message.act === 'close') | ||
| 263 | - close(worker, message); | ||
| 262 | + const fn = methodMessageMapping[message.act]; | ||
| 263 | + | ||
| 264 | + if (typeof fn === 'function') | ||
| 265 | + fn(worker, message); | ||
| 264 | 266 | } | |
| 265 | 267 | ||
| 266 | 268 | function online(worker) { | |
| Back | FazBrowse Home | New Git URL |
0 commit comments