* Gets the next event. * @returns {Promise }
()
| 648 | * @returns {Promise<IteratorResult>} |
| 649 | */ |
| 650 | next() { |
| 651 | if (this.#closed) { |
| 652 | return PromiseResolve({ done: true, value: undefined }); |
| 653 | } |
| 654 | |
| 655 | if (this.#pendingEvents.length > 0) { |
| 656 | const event = this.#pendingEvents.shift(); |
| 657 | return PromiseResolve({ done: false, value: event }); |
| 658 | } |
| 659 | |
| 660 | return new Promise((resolve, reject) => { |
| 661 | ArrayPrototypePush(this.#pendingResolvers, { resolve, reject }); |
| 662 | }); |
| 663 | } |
| 664 | |
| 665 | /** |
| 666 | * Closes the iterator and underlying watcher. |