(&self, msg: PingMessage)
| 101 | } |
| 102 | |
| 103 | fn send_ping_msg(&self, msg: PingMessage) -> impl Future<Output = ()> + use<> { |
| 104 | let ping_msg_sender = self.ping_msg_sender.clone(); |
| 105 | let max_ping_time = self.max_ping_time; |
| 106 | async move { |
| 107 | if max_ping_time == 0 { |
| 108 | return; |
| 109 | } |
| 110 | if ping_msg_sender.send(msg).await.is_err() { |
| 111 | error!("Cannot ping, no event loop available."); |
| 112 | } |
| 113 | } |
| 114 | } |
| 115 | |
| 116 | pub fn start_ping_timer(&self) -> impl Future<Output = ()> + use<> { |
| 117 | self.send_ping_msg(PingMessage::StartTimer) |
no test coverage detected