| 73 | td::actor::send_closure(id_, &TcpClientImpl::process_query_answer, connection_id_, query_id, std::move(data)); |
| 74 | } |
| 75 | void on_query_error(td::actor::ActorId<TcpConnection> conn, td::int64 query_id, td::Status error) override { |
| 76 | td::actor::send_closure(id_, &TcpClientImpl::process_query_error, connection_id_, query_id, std::move(error)); |
| 77 | } |
| 78 | Cb(td::actor::ActorId<TcpClientImpl> id, ConnectionId connection_id) : id_(id), connection_id_(connection_id) { |
| 79 | } |
| 80 | }; |