| 210 | : id_(id), listening_socket_id_(listening_socket_id) { |
| 211 | } |
| 212 | void accept(td::SocketFd fd) override { |
| 213 | td::actor::send_closure(id_, &TcpClientImpl::accepted_tcp_connection, td::BufferedFd<td::SocketFd>(std::move(fd)), |
| 214 | listening_socket_id_); |
| 215 | } |
| 216 | }; |
| 217 | |
| 218 | listening_socket->listener = td::actor::create_actor<td::TcpInfiniteListener>( |
nothing calls this directly
no outgoing calls
no test coverage detected