fix: allow to use unix sockets in connect (#1852)

Fixes #1040
mqttjs · Apr 26, 2024 · 22c97b5 · 22c97b5
1 parent f62e207
commit 22c97b5
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/lib/connect/tcp.ts b/src/lib/connect/tcp.ts
@@ -13,11 +13,11 @@ const buildStream: StreamBuilder = (client, opts) => {
 	opts.port = opts.port || 1883
 	opts.hostname = opts.hostname || opts.host || 'localhost'
 
-	const { port } = opts
+	const { port, path } = opts
 	const host = opts.hostname
 
 	debug('port %d and host %s', port, host)
-	return net.createConnection(port, host)
+	return net.createConnection({ port, host, path })
 }
 
 export default buildStream