()
| 66 | |
| 67 | // Advance to the next message's ack time, and deliver the ack to the flow controller. |
| 68 | waitForNextAck() { |
| 69 | let entry = this.inFlight.shift(); |
| 70 | if (entry) { |
| 71 | this.t = entry.ackTime; |
| 72 | if (this.fc.onAck(entry.token)) { |
| 73 | this.blocked = false; |
| 74 | } |
| 75 | } |
| 76 | } |
| 77 | |
| 78 | // Simulate the application writing to the stream as fast as it can for the given duration. |
| 79 | saturateFor(duration: number): void { |
no test coverage detected