(value: T)
| 32 | } |
| 33 | |
| 34 | enqueue(value: T): void { |
| 35 | if (this.readResolve) { |
| 36 | const resolve = this.readResolve |
| 37 | this.readResolve = undefined |
| 38 | this.readReject = undefined |
| 39 | resolve({ done: false, value }) |
| 40 | } else { |
| 41 | this.queue.push(value) |
| 42 | } |
| 43 | } |
| 44 | |
| 45 | done(): void { |
| 46 | this.isDone = true |