Merge branch 'v2' into dev

performance/leakage/on-off.test.js

@@ -0,0 +1,37 @@
+const test = require('tape')
+const { iterate } = require('leakage')
+const { EventEmitter } = require('events')
+
+const { CQWebSocket } = require('../../')
+
+test('EventEmitter#on(), EventEmitter#removeAllListener()', function (t) {
+  const bot = new EventEmitter()
+  iterate(() => {
+    let a = 0
+    bot.on('message', function (arg) {
+      // zero side effect
+      arg++
+    })
+    bot.emit('message', a)
+    bot.removeAllListeners('message')
+  })
+  t.same(bot.listeners('message').length, 0)
+  t.end()
+})
+
+test('CQWebSocket#on(), CQWebSocket#off()', function (t) {
+  const bot = new CQWebSocket()
+  iterate.async(async () => {
+    let a = 0
+    bot.on('message', function (arg) {
+      // zero side effect
+      arg++
+    })
+    await bot._eventBus.emit('message', a)
+    bot.off('message')
+  })
+    .then(function () {
+      t.same(bot._eventBus._EventMap.message[''].length, 0)
+      t.end()
+    })
+})

performance/leakage/once.test.js

@@ -0,0 +1,35 @@
+const test = require('tape')
+const { iterate } = require('leakage')
+const { EventEmitter } = require('events')
+
+const { CQWebSocket } = require('../../')
+
+test('EventEmitter#once()', function (t) {
+  const bot = new EventEmitter()
+  iterate(() => {
+    let a = 0
+    bot.once('message', function (arg) {
+      // zero side effect
+      arg++
+    })
+    bot.emit('message', a)
+  })
+  t.same(bot.listeners('message').length, 0)
+  t.end()
+})
+
+test('CQWebSocket#once()', function (t) {
+  const bot = new CQWebSocket()
+  iterate.async(() => {
+    let a = 0
+    bot.once('message', function (arg) {
+      // zero side effect
+      arg++
+    })
+    return bot._eventBus.emit('message', a)
+  })
+    .then(function () {
+      t.same(bot._eventBus._EventMap.message[''].length, 0)
+      t.end()
+    })
+})