diff --git a/package.json b/package.json index cf8179478388dc7daebcbda03d332c90dc3336ab..5ceb3631516de522f8a82306422c90bcdb91e713 100644 --- a/package.json +++ b/package.json @@ -100,7 +100,7 @@ "read-pkg-up": "^2.0", "request": "^2.83", "retry-promise": "^1.0", - "rx-queue": "^0.0", + "rx-queue": "^0.1", "rxjs": "^5.4", "state-switch": "^0.2", "watchdog": "^0.3", diff --git a/src/puppet-web/puppet-web.ts b/src/puppet-web/puppet-web.ts index 1a3134ac791baff2ab56ea59c70bfdc752a759a1..0dc4fa1d7a947b973e63eaa7dd1d4db1b6486a66 100644 --- a/src/puppet-web/puppet-web.ts +++ b/src/puppet-web/puppet-web.ts @@ -113,8 +113,8 @@ export class PuppetWeb extends Puppet { const throttleQueue = new ThrottleQueue(5 * 60 * 1000) this.on('heartbeat', data => throttleQueue.next(data)) - throttleQueue.subscribe(async () => { - log.verbose('Wechaty', 'init() throttleQueue.subscribe() new event fired') + throttleQueue.subscribe(async data => { + log.verbose('Wechaty', 'init() throttleQueue.subscribe() new item: %s', data) await this.saveCookie() })