Remove a session (connection closed).
(&self, addr: &SocketAddr)
| 38 | |
| 39 | /// Remove a session (connection closed). |
| 40 | pub fn remove(&self, addr: &SocketAddr) { |
| 41 | let mut sessions = self.sessions.write().unwrap_or_else(|p| p.into_inner()); |
| 42 | sessions.remove(addr); |
| 43 | } |
| 44 | |
| 45 | /// List all active sessions as (peer_address, transaction_state) pairs. |
| 46 | pub fn all_sessions(&self) -> Vec<(String, String)> { |