(stream, promise, action)
| 1591 | } |
| 1592 | |
| 1593 | function watchClosed(stream, promise, action) { |
| 1594 | if (stream[kState].state === 'closed') |
| 1595 | action(); |
| 1596 | else |
| 1597 | PromisePrototypeThen(promise, action, () => {}); |
| 1598 | } |
| 1599 | |
| 1600 | async function step() { |
| 1601 | if (shuttingDown) return true; |
no test coverage detected