fix(ipc): disable resubscription

boneskull · boneskull · commit 407cdf2e2f47 · 2018-02-01T21:57:51.000-08:00
diff --git a/lib/index.js b/lib/index.js
@@ -183,7 +183,9 @@ exports.connect = async (url, opts = {}) => {
   }
   return new Promise((resolve, reject) => {
     (opts.path
-      ? MQTT.MqttClient(() => net.createConnection(opts.path))
+      ? MQTT.MqttClient(() => net.createConnection(opts.path), {
+          resubscribe: false
+        })
       : MQTT.connect(...args)
     )
       .on('connect', function(connack) {

Original file line number	Diff line number	Diff line change
`@@ -183,7 +183,9 @@ exports.connect = async (url, opts = {}) => {`
`183`	`183`	`}`
`184`	`184`	`return new Promise((resolve, reject) => {`
`185`	`185`	`(opts.path`
`186`		`- ? MQTT.MqttClient(() => net.createConnection(opts.path))`
	`186`	`+ ? MQTT.MqttClient(() => net.createConnection(opts.path), {`
	`187`	`+ resubscribe: false`
	`188`	`+ })`
`187`	`189`	`: MQTT.connect(...args)`
`188`	`190`	`)`
`189`	`191`	`.on('connect', function(connack) {`