| 43 | } |
| 44 | |
| 45 | td::actor::Task<Action> task_loop_once() override { |
| 46 | co_await left_.flush_read(); |
| 47 | co_await right_.flush_read(); |
| 48 | // LOG(INFO) << "left=" << left_.input_buffer().size() << " right=" << right_.input_buffer().size(); |
| 49 | proxy_sockets(left_, right_); |
| 50 | proxy_sockets(right_, left_); |
| 51 | co_await left_.flush_write(); |
| 52 | co_await right_.flush_write(); |
| 53 | co_return Action::KeepRunning; |
| 54 | } |
| 55 | |
| 56 | td::actor::Task<td::Unit> finish(td::Status status) override { |
| 57 | co_await std::move(status); |
nothing calls this directly
no test coverage detected