| 532 | test_mt_handler::on_connection_open(c); |
| 533 | } |
| 534 | void initiate_close() { |
| 535 | std::unique_lock<std::mutex> l(wqlock_); |
| 536 | wq_->add(call_do_close_); |
| 537 | } |
| 538 | void do_close() { connection_.close(); } |
| 539 | void on_connection_close(proton::connection &) override { set("closed"); } |
| 540 | }; |
no test coverage detected