this.logger = logger;
this.db = db;
- this.options = Object.assign({}, defaultOptions, options);
+ this.options = {
+ ...defaultOptions,
+ ...options,
+ };
this.notificationEventName = 'notification';
this.connection = null;
/**
* Notify callback.
- * @param {Object} data
+ * @param {object} data listener notification
*/
async _onNotification(data) {
const _scope = _fileScope('_onNotification');
/**
* Notify callback and attempt to reconnect.
- * @param {*} error
- * @param {*} event
+ * @param {*} error error
+ * @param {*} event event
*/
async _onConnectionLost(error, event) {
const _scope = _fileScope('_onConnectionLost');
/**
* Schedule an attempt to establish a connection.
- * @param {Number} delay
- * @param {Number} retriesRemaining
+ * @param {number} delay reconnect delay
+ * @param {number} retriesRemaining retry countdown
*/
async _reconnect(delay, retriesRemaining) {
const _scope = _fileScope('_reconnect');