The consumer stopped pulling; wake waiters so they can observe it.
()
| 97 | |
| 98 | /** The consumer stopped pulling; wake waiters so they can observe it. */ |
| 99 | noteConsumerDetached(): void { |
| 100 | if (this.consumerDetached) return; |
| 101 | this.consumerDetached = true; |
| 102 | this.wake(); |
| 103 | } |
| 104 | |
| 105 | /** Resolves on the next push/ack/close/error/wake — a condition-variable wait. */ |
| 106 | waitForProgress(): Promise<void> { |
no test coverage detected