| 170 | } |
| 171 | |
| 172 | void on_receiver_open(proton::receiver &r) override { |
| 173 | receiver_ = r; |
| 174 | next_idle_ = proton::make_work(&tester::first_idle, this); |
| 175 | proton::work call_on_server_idle(make_work(&tester::on_server_idle, this)); |
| 176 | srv_->notify_on_idle(r.work_queue(), call_on_server_idle); |
| 177 | r.add_credit(initial_credit_); |
| 178 | } |
| 179 | |
| 180 | void on_message(proton::delivery &d, proton::message &m) override { |
| 181 | received_++; |
nothing calls this directly
no test coverage detected