Comparing version 0.0.2 to 0.0.3
@@ -49,2 +49,3 @@ const connect = require('./connect'); | ||
this.connect.unsubscribe(topic, cb); | ||
delete this.map['topic']; | ||
}; |
const mqtt = require('mqtt'); | ||
const _ = require('lodash'); | ||
module.exports = function (options) { | ||
options = options || {host: 'localhost', port: '1883'}; | ||
if (typeof options === "object") { | ||
options = _.pick(options, ['host', 'port']); | ||
} | ||
const connect = mqtt.connect(options); | ||
return connect; | ||
}; |
{ | ||
"name": "pubsubr", | ||
"version": "0.0.2", | ||
"version": "0.0.3", | ||
"description": "pub and sub to loopback components", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
Major refactor
Supply chain riskPackage has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.
Found 1 instance in 1 package
19325
519
0