refactor(pushqueue): Tidy cleanup.

Author: timoxley

src/utils/PushQueue.ts

@@ -234,21 +234,22 @@ export default class PushQueue<T> {
     }
 
     async _cleanup() {
+        const { error, nextQueue } = this
         this.finished = true
-        const { error } = this
-        const queue = this.nextQueue
         this.error = undefined
-        this.nextQueue = []
         this.pending = 0
         this.buffer.length = 0
-        while (queue.length) {
-            const p = queue.shift()
+        this.buffer = []
+        this.nextQueue = []
+        const doneValue = { value: undefined, done: true }
+        while (nextQueue.length) {
+            const p = nextQueue.shift()
             if (!p) { continue }
 
             if (error) {
                 p.reject(error)
             } else {
-                p.resolve(undefined)
+                p.resolve(doneValue)
             }
         }
 

test/memory/MessageQuantity.test.ts

@@ -223,7 +223,7 @@ describe('no memleaks when processing a high quantity of large messages', () =>
             }, MAX_TEST_TIME * 2)
         })
 
-        test('resend', async () => {
+        test('just resend', async () => {
             const MAX_MEMORY_USAGE = 5e+8 // 500MB
             const MAX_MESSAGES = 60000 // 60k
             const end = 1616509054932