Skip to content
This repository was archived by the owner on Nov 23, 2022. It is now read-only.

Commit f06382d

Browse files
committed
add: queueManager
1 parent e52f8ae commit f06382d

File tree

1 file changed

+18
-0
lines changed

1 file changed

+18
-0
lines changed

index.js

Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,18 @@
1+
function QueueManager(queue) {
2+
this._emitter = new EventEmitter();
3+
const self = this;
4+
queue.drain(() => {
5+
self._emitter.emit("toggle");
6+
});
7+
}
8+
9+
QueueManager.prototype.pause = function () {
10+
const self = this;
11+
return new Promise((resolve) => {
12+
self._emitter.on("toggle", () => resolve(true));
13+
});
14+
};
15+
16+
QueueManager.prototype.resume = function () {
17+
this._emitter.emit("toggle");
18+
};

0 commit comments

Comments
 (0)