Consumer-side ack: one event has been fully processed (not just received).
()
| 91 | |
| 92 | /** Consumer-side ack: one event has been fully processed (not just received). */ |
| 93 | ackConsumed(): void { |
| 94 | this.consumedCount += 1; |
| 95 | this.wake(); |
| 96 | } |
| 97 | |
| 98 | /** The consumer stopped pulling; wake waiters so they can observe it. */ |
| 99 | noteConsumerDetached(): void { |