fix(types): better streamBuilder types

src/lib/connect/ali.ts

@@ -122,7 +122,7 @@ const buildStream: StreamBuilder = (client, opts) => {
 
 	bindEventHandler()
 
-	return stream as unknown as Duplex
+	return stream
 }
 
 export default buildStream

src/lib/connect/index.ts

@@ -1,15 +1,12 @@
 /* eslint-disable @typescript-eslint/no-var-requires */
+import _debug from 'debug'
 import url from 'url'
 import MqttClient, {
 	IClientOptions,
 	MqttClientEventCallbacks,
 	MqttProtocol,
 } from '../client'
 import IS_BROWSER from '../is-browser'
-import Store from '../store'
-import DefaultMessageIdProvider from '../default-message-id-provider'
-import UniqueMessageIdProvider from '../unique-message-id-provider'
-import _debug from 'debug'
 import { StreamBuilder } from '../shared'
 
 const debug = _debug('mqttjs')

src/lib/connect/tcp.ts

@@ -17,7 +17,7 @@ const buildStream: StreamBuilder = (client, opts) => {
 	const host = opts.hostname
 
 	debug('port %d and host %s', port, host)
-	return net.createConnection(port, host) as unknown as Duplex
+	return net.createConnection(port, host)
 }
 
 export default buildStream

src/lib/connect/tls.ts

@@ -49,7 +49,7 @@ const buildStream: StreamBuilder = (client, opts) => {
 	}
 
 	connection.on('error', handleTLSerrors)
-	return connection as unknown as Duplex
+	return connection
 }
 
 export default buildStream

src/lib/connect/ws.ts

@@ -137,13 +137,12 @@ const streamBuilder: StreamBuilder = (client, opts) => {
 		socket,
 		options.wsOptions as DuplexOptions,
 	)
-	// eslint-disable-next-line @typescript-eslint/ban-ts-comment
-	// @ts-ignore
-	webSocketStream.url = url
+
+	webSocketStream['url'] = url
 	socket.on('close', () => {
 		webSocketStream.destroy()
 	})
-	return webSocketStream as Duplex
+	return webSocketStream
 }
 
 const browserStreamBuilder: StreamBuilder = (client, opts) => {

src/lib/connect/wx.ts

@@ -135,7 +135,7 @@ const buildStream: StreamBuilder = (client, opts) => {
 
 	bindEventHandler()
 
-	return stream as unknown as Duplex
+	return stream
 }
 
 export default buildStream

src/lib/shared.ts

@@ -1,15 +1,15 @@
-import type { IClientOptions } from './client'
+import type { Packet } from 'mqtt-packet'
+import type internal from 'stream'
 import type MqttClient from './client'
-import { Packet } from 'mqtt-packet'
-import { Duplex, Writable } from 'readable-stream'
+import type { IClientOptions } from './client'
 
 export type DoneCallback = (error?: Error) => void
 
 export type GenericCallback<T> = (error?: Error, result?: T) => void
 
 export type VoidCallback = () => void
 
-export type IStream = Duplex | Writable
+export type IStream = internal.Duplex
 
 export type StreamBuilder = (
 	client: MqttClient,

src/mqtt.ts

@@ -22,4 +22,5 @@ export {
 	IStore,
 }
 export * from './lib/client'
+export * from './lib/shared'
 export { ReasonCodes } from './lib/handlers/ack'