| 59 | } |
| 60 | |
| 61 | void on_connection_open(proton::connection& c) override { |
| 62 | if (c.reconnected()) { |
| 63 | sent = confirmed; // Re-send unconfirmed messages after a reconnect |
| 64 | } |
| 65 | } |
| 66 | |
| 67 | void on_sendable(proton::sender &s) override { |
| 68 | while (s.credit() && sent < total) { |
nothing calls this directly
no test coverage detected