(value: T)
| 37 | } |
| 38 | |
| 39 | enqueue(value: T): void { |
| 40 | if (this.readResolve) { |
| 41 | const resolve = this.readResolve |
| 42 | this.readResolve = undefined |
| 43 | this.readReject = undefined |
| 44 | resolve({ done: false, value }) |
| 45 | } else { |
| 46 | this.queue.push(value) |
| 47 | } |
| 48 | } |
| 49 | |
| 50 | done() { |
| 51 | this.isDone = true |