Use @joepie91/consumable

package.json

@@ -6,6 +6,7 @@
   "author": "Sven Slootweg <admin@cryto.net>",
   "license": "WTFPL OR CC0-1.0",
   "dependencies": {
+    "@joepie91/consumable": "^1.0.1",
     "@promistream/is-aborted": "^0.1.1",
     "@promistream/is-end-of-stream": "^0.1.1",
     "@promistream/pipe": "^0.1.4",

promise-listener.js

@@ -1,19 +1,19 @@
 "use strict";
 
+const consumable = require("@joepie91/consumable");
+
 module.exports = function createPromiseListener() {
-	let listeners = [];
+	let listeners = consumable([]);
 
 	function consumeListeners() {
 		/* To ensure that a resolve/reject is atomic, and can never apply to the same listener queue twice. */
-		let consumedListeners = listeners;
+		return listeners.replace([]);
-		listeners = [];
-		return consumedListeners;
 	}
 
 	return {
 		listen: function () {
 			return new Promise((resolve, reject) => {
-				listeners.push({ resolve, reject });
+				listeners.peek().push({ resolve, reject });
 			});
 		},
 		resolve: function (value) {
@@ -27,4 +27,4 @@ module.exports = function createPromiseListener() {
 			});
 		},
 	}
-};
+};