diff --git a/src/lib/client.ts b/src/lib/client.ts index 5a82df1da..8d11e8e2d 100644 --- a/src/lib/client.ts +++ b/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,7 +1308,7 @@ export default class MqttClient extends TypedEventEmitter public unsubscribeAsync( topic: string | string[], - opts?: IClientSubscribeOptions, + opts?: IClientUnsubscribeProperties, ): Promise public unsubscribeAsync( topic: string | string[], - opts?: IClientSubscribeOptions, + opts?: IClientUnsubscribeProperties, ): Promise { return new Promise((resolve, reject) => { this.unsubscribe(topic, opts, (err, packet) => {