clean rx-queue

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",

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()
       })