| 438 | } |
| 439 | |
| 440 | std::string wait() { |
| 441 | std::unique_lock<std::mutex> l(lock_); |
| 442 | while (str_.empty()) cond_.wait(l); |
| 443 | std::string s = str_; |
| 444 | str_.clear(); |
| 445 | return s; |
| 446 | } |
| 447 | |
| 448 | proton::error_condition error() const { return err_; } |
| 449 | void on_container_start(proton::container &) override { set("start"); } |