Merge 16c85a7 into dde5951

lwmqn · Jun 3, 2019 · 77a3f2e · 77a3f2e
2 parents dde5951 + 16c85a7
commit 77a3f2e
Show file tree

Hide file tree

Showing 3 changed files with 359 additions and 400 deletions.
diff --git a/.travis.yml b/.travis.yml
@@ -4,3 +4,4 @@ node_js:
   - "10"
   - "12"
 after_success: npm run coverage
+
diff --git a/lib/init.js b/lib/init.js
@@ -1,5 +1,3 @@
-
-const _ = require('busyman')
 const debug = require('debug')('mqtt-node:init')
 const reporter = require('./reporter')
 const msgHandlers = require('./msg_handlers')
@@ -99,7 +97,7 @@ module.exports = function (qn) {
     const isReadable = so.isReadable(oid, iid, rid)
     let dataToCheck
 
-    if (_.isFunction(opt)) {
+    if (typeof opt === 'function') {
       callback = opt
       opt = undefined
     }
@@ -121,7 +119,7 @@ module.exports = function (qn) {
     const isReadable = so.isReadable(oid, iid, rid)
     let dataToCheck
 
-    if (_.isFunction(opt)) {
+    if (typeof opt === 'function') {
       callback = opt
       opt = undefined
     }
@@ -140,7 +138,8 @@ module.exports = function (qn) {
 
   debug('Set up LWMQN interfaces')
 
-  _.forEach(['register', 'deregister', 'schedule', 'notify', 'update', 'ping'], (intf) => {
+  const eventList = [ 'register', 'deregister', 'schedule', 'notify', 'update', 'ping' ]
+  eventList.forEach((intf) => {
     qn._pubics[intf] = `${intf}/${qn.clientId}`
     qn._subics[intf] = `${intf}/response/${qn.clientId}`
   })