How to use the rx-queue.ThrottleQueue function in rx-queue

RxQueue,
  ThrottleQueue,
  VERSION,
}                 from 'rx-queue'

if (VERSION === '0.0.0') {
  throw new Error('version should be set before publishing')
}

const rq = new RxQueue()
console.info(`RxQueue v${rq.version()}`)

const dq = new DelayQueue()
console.info(`DelayQueue v${dq.version()}`)

const tq = new ThrottleQueue()
console.info(`ThrottleQueue v${tq.version()}`)

console.info('Smoke Testing PASSED!')

/**
     * Throttle for 10 seconds
     */
    this.throttleQueue = new ThrottleQueue(1000 * 10)
    /**
     * Debounce for 20 seconds
     */
    this.debounceQueue = new DebounceQueue(1000 * 10 * 2)

    /**
     * Throttle for 5 seconds for the `logout` event:
     *  we should only fire once for logout,
     *  but the server will send many events of 'logout'
     */
    this.logoutThrottleQueue = new ThrottleQueue(1000 * 5)

    this.initHeartbeat()

    if (this.logoutThrottleSubscription) {
      throw new Error('this.logoutThrottleSubscription exist')
    } else {
      this.logoutThrottleSubscription = this.logoutThrottleQueue.subscribe(async msg => {
        await this.reset(msg)
      })
    }
  }

private startQueues() {
    log.verbose('PadchatRpc', 'startQueues()')

    /**
     * Throttle for 10 seconds
     */
    this.throttleQueue = new ThrottleQueue(1000 * 10)
    /**
     * Debounce for 20 seconds
     */
    this.debounceQueue = new DebounceQueue(1000 * 10 * 2)

    /**
     * Throttle for 5 seconds for the `logout` event:
     *  we should only fire once for logout,
     *  but the server will send many events of 'logout'
     */
    this.logoutThrottleQueue = new ThrottleQueue(1000 * 5)

    this.initHeartbeat()

    if (this.logoutThrottleSubscription) {
      throw new Error('this.logoutThrottleSubscription exist')