Class Cb

net/TcpClient.cpp:52–80

std::unique_ptr<TcpConnection::Callback> TcpClientImpl::make_tcp_connection_callback(
    TcpClient::ConnectionId connection_id) {
  class Cb : public TcpConnection::Callback {
   private:
    td::actor::ActorId<TcpClientImpl> id_;
    ConnectionId connection_id_;

   public:
    void on_ready(td::actor::ActorId<TcpConnection> conn, const RemoteAppType &remote_app_type,
                  const td::Bits256 &remote_app_hash, const td::Bits256 &verified_by) override {
      td::actor::send_closure(id_, &TcpClientImpl::conn_ready, connection_id_, remote_app_type, remote_app_hash,
                              verified_by);
    }
    void on_close(td::actor::ActorId<TcpConnection> conn) override {
      td::actor::send_closure(id_, &TcpClientImpl::conn_stopped, connection_id_);
    }
    void on_packet(td::actor::ActorId<TcpConnection> conn, td::BufferSlice data) override {
      td::actor::send_closure(id_, &TcpClientImpl::process_packet, connection_id_, std::move(data));
    }
    void on_query(td::actor::ActorId<TcpConnection> conn, td::int64 query_id, td::BufferSlice data) override {
      td::actor::send_closure(id_, &TcpClientImpl::process_query, connection_id_, query_id, std::move(data));
    }
    void on_query_answer(td::actor::ActorId<TcpConnection> conn, td::int64 query_id, td::BufferSlice data) override {
      td::actor::send_closure(id_, &TcpClientImpl::process_query_answer, connection_id_, query_id, std::move(data));
    }
    void on_query_error(td::actor::ActorId<TcpConnection> conn, td::int64 query_id, td::Status error) override {
      td::actor::send_closure(id_, &TcpClientImpl::process_query_error, connection_id_, query_id, std::move(error));
    }
    Cb(td::actor::ActorId<TcpClientImpl> id, ConnectionId connection_id) : id_(id), connection_id_(connection_id) {
    }
  };
  return std::make_unique<Cb>(actor_id(this), connection_id);
}