Comparing version 1.4.2 to 1.4.3
@@ -15,2 +15,3 @@ "use strict"; | ||
const debug = require("debug"); | ||
const reconnect_strategy_1 = require("./reconnect-strategy"); | ||
class MqttClient extends mqtt_base_client_1.MqttBaseClient { | ||
@@ -31,3 +32,10 @@ constructor(options) { | ||
this.messageListener = new mqtt_listener_1.MqttListener(); | ||
this.reconnectStrategy = options.autoReconnect; | ||
if (typeof options.autoReconnect === 'boolean') { | ||
this.reconnectStrategy = options.autoReconnect | ||
? new reconnect_strategy_1.MqttsReconnectStrategyDefault() | ||
: new reconnect_strategy_1.MqttsReconnectStrategyDefault(0); | ||
} | ||
else { | ||
this.reconnectStrategy = options.autoReconnect; | ||
} | ||
this.transport = | ||
@@ -34,0 +42,0 @@ (_a = options.transport) !== null && _a !== void 0 ? _a : new transport_1.TlsTransport({ |
@@ -6,6 +6,5 @@ import { ConnectRequestOptions } from './packets'; | ||
import { MqttMessage } from './mqtt.message'; | ||
import { DefaultPacketReadResultMap, PacketReadMap, PacketReadResultMap } from './packets/packet-reader'; | ||
import { DefaultPacketWriteOptions, PacketWriteMap, PacketWriteOptionsMap, PacketWriter } from './packets/packet-writer'; | ||
import { DefaultPacketReadResultMap, PacketReadMap, PacketReadResultMap, DefaultPacketWriteOptions, PacketWriteMap, PacketWriteOptionsMap, PacketWriter } from './packets'; | ||
import { TransformerFn, ValidatorFn } from './mqtt.listener'; | ||
import { MqttsReconnectStrategy } from './reconnect-strategy/mqtts.reconnect-strategy'; | ||
import { MqttsReconnectStrategy } from './reconnect-strategy'; | ||
export declare type MqttClientConstructorOptions<ReadMap extends PacketReadResultMap = DefaultPacketReadResultMap, WriteMap extends PacketWriteOptionsMap = DefaultPacketWriteOptions> = XOR<{ | ||
@@ -22,8 +21,4 @@ transport: Transport<unknown>; | ||
packetWriter?: PacketWriter<WriteMap>; | ||
autoReconnect?: MqttsReconnectStrategy; | ||
autoReconnect?: MqttsReconnectStrategy | boolean; | ||
}; | ||
export interface MqttAutoReconnectOptions { | ||
maxReconnectAttempts?: number; | ||
resetOnConnect?: boolean; | ||
} | ||
export interface MqttSubscription { | ||
@@ -30,0 +25,0 @@ topic: string; |
{ | ||
"name": "mqtts", | ||
"version": "1.4.2", | ||
"version": "1.4.3", | ||
"description": "MQTT client in Typescript", | ||
@@ -5,0 +5,0 @@ "main": "dist/index.js", |
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
174397
2644