| 346 | promise.set_value(td::Unit()); |
| 347 | } |
| 348 | void BaseRunner::http_server_initialized() { |
| 349 | initialize_rpc_server([self_id = actor_id(this)](td::Result<td::Unit> R) { |
| 350 | if (R.is_error()) { |
| 351 | td::actor::send_closure(self_id, &BaseRunner::initialization_failure, |
| 352 | R.move_as_error_prefix("failed to initialize rpc server: ")); |
| 353 | } else { |
| 354 | td::actor::send_closure(self_id, &BaseRunner::rpc_server_initialized); |
| 355 | } |
| 356 | }); |
| 357 | } |
| 358 | void BaseRunner::initialize_rpc_server(td::Promise<td::Unit> promise) { |
| 359 | client_ = TcpClient::create(make_tcp_client_callback()); |
| 360 | for (auto &x : rpc_ports_) { |
nothing calls this directly
no outgoing calls
no test coverage detected