diff --git a/zed-rpc/src/peer.rs b/zed-rpc/src/peer.rs index 0d39b84eb50b0c43f16e30b903194fc0d84eb494..6f319d533c6b633b39bfd8e53db29c0401ec9011 100644 --- a/zed-rpc/src/peer.rs +++ b/zed-rpc/src/peer.rs @@ -148,6 +148,13 @@ impl Peer { .remove(&connection_id); } + pub async fn reset(&self) { + self.connections.write().await.clear(); + self.connection_close_barriers.write().await.clear(); + self.handler_types.lock().await.clear(); + self.message_handlers.write().await.clear(); + } + pub fn handle_messages( self: &Arc, connection_id: ConnectionId,