Method process_query

net/TcpClient.hpp:321–335

    }
  }
  void process_query(ConnectionId connection_id, QueryId id, td::BufferSlice data) {
    LOG(DEBUG) << "tcp: processing query from " << connection_id;
    auto it = active_connections_.find(connection_id);
    if (it == active_connections_.end()) {
      return;
    }
    auto P = td::PromiseCreator::lambda([self_id = actor_id(this), id, connection_id](td::Result<td::BufferSlice> R) {
      if (R.is_ok()) {
        td::actor::send_closure(self_id, &TcpClientImpl::send_query_answer, connection_id, id, R.move_as_ok());
      } else {
        td::actor::send_closure(self_id, &TcpClientImpl::send_query_answer_error, connection_id, id, R.move_as_error());
      }
    });
    callback_->receive_query(connection_id, std::move(data), std::move(P));
  }
  void unregister_query(QueryId query_id) {
    out_queries_.erase(query_id);
  }