for (const [source, queue] of this.inputQueues.entries()) {
                    if (!sources.includes(source)) {
                        while (queue.length) {
                            const data = queue.shift();
                            this.emit('reject', data);