Merge branch 'main' into SubackCallback

src/lib/client.ts

@@ -323,7 +323,7 @@ export interface IClientReconnectOptions {
 }
 export interface IClientSubscribeProperties {
 	/*
-	 *  MQTT 5.0 properies object of subscribe
+	 *  MQTT 5.0 properties object of subscribe
 	 * */
 	properties?: ISubscribePacket['properties']
 }
@@ -370,6 +370,13 @@ export type ISubscriptionMap = {
 	resubscribe?: boolean
 }
 
+export interface IClientUnsubscribeProperties {
+	/*
+	 *  MQTT 5.0 properties object for unsubscribe
+	 * */
+	properties?: IUnsubscribePacket['properties']
+}
+
 export { IConnackPacket, IDisconnectPacket, IPublishPacket, Packet }
 export type OnConnectCallback = (packet: IConnackPacket) => void
 export type OnDisconnectCallback = (packet: IDisconnectPacket) => void
@@ -1301,20 +1308,20 @@ export default class MqttClient extends TypedEventEmitter<MqttClientEventCallbac
 	public unsubscribe(topic: string | string[]): MqttClient
 	public unsubscribe(
 		topic: string | string[],
-		opts?: IClientSubscribeOptions,
+		opts?: IClientUnsubscribeProperties,
 	): MqttClient
 	public unsubscribe(
 		topic: string | string[],
 		callback?: PacketCallback,
 	): MqttClient
 	public unsubscribe(
 		topic: string | string[],
-		opts?: IClientSubscribeOptions,
+		opts?: IClientUnsubscribeProperties,
 		callback?: PacketCallback,
 	): MqttClient
 	public unsubscribe(
 		topic: string | string[],
-		opts?: IClientSubscribeOptions | PacketCallback,
+		opts?: IClientUnsubscribeProperties | PacketCallback,
 		callback?: PacketCallback,
 	): MqttClient {
 		if (typeof topic === 'string') {
@@ -1396,11 +1403,11 @@ export default class MqttClient extends TypedEventEmitter<MqttClientEventCallbac
 	): Promise<Packet | undefined>
 	public unsubscribeAsync(
 		topic: string | string[],
-		opts?: IClientSubscribeOptions,
+		opts?: IClientUnsubscribeProperties,
 	): Promise<Packet | undefined>
 	public unsubscribeAsync(
 		topic: string | string[],
-		opts?: IClientSubscribeOptions,
+		opts?: IClientUnsubscribeProperties,
 	): Promise<Packet | undefined> {
 		return new Promise((resolve, reject) => {
 			this.unsubscribe(topic, opts, (err, packet) => {