Method initialize_http_server

runners/BaseRunner.cpp:320–347

  });
}
void BaseRunner::initialize_http_server(td::Promise<td::Unit> promise) {
  if (http_port_ > 0) {
    class Cb : public http::HttpCallback {
     public:
      Cb(td::actor::ActorId<BaseRunner> client, td::actor::Scheduler *scheduler)
          : client_(std::move(client)), scheduler_(scheduler) {
      }
      void receive_request(http::HttpCallback::RequestType request_type,
                           std::vector<std::pair<std::string, std::string>> headers, std::string path,
                           std::vector<std::pair<std::string, std::string>> args, std::string body,
                           std::unique_ptr<http::HttpRequestCallback> answer_callback) override {
        CHECK(answer_callback);
        scheduler_->run_in_context([&]() {
          td::actor::send_closure_later(client_, &BaseRunner::receive_http_request_outer, request_type,
                                        std::move(headers), std::move(path), std::move(args), std::move(body),
                                        std::move(answer_callback));
        });
      }

     private:
      td::actor::ActorId<BaseRunner> client_;
      td::actor::Scheduler *scheduler_;
    };

    http::init_http_server(http_port_, std::make_shared<Cb>(actor_id(this), scheduler_));
  }
  promise.set_value(td::Unit());
}
void BaseRunner::http_server_initialized() {
  initialize_rpc_server([self_id = actor_id(this)](td::Result<td::Unit> R) {
    if (R.is_error()) {