async fn manage_peer(mut self, id: PeerId, mut stream: PeerHandlerRequestStream) {
        while let Some(Ok(request)) = stream.next().await {
            if let Err(e) = self.handle_peer_request(id, request).await {
                fx_log_err!("{}", e);
                break;
            };
        }
        self.inner.lock().await.peers.remove(&id);
    }
/// Handle all PeerHandlerRequests for a peer, removing the peer after the request stream
/// is closed.
///
/// Arguments:
///     `id`: The unique id for the peer that initiated the stream.
///     `stream`: A stream of requests associated with a single peer.
Handle all PeerHandlerRequests for a peer, removing the peer after the request stream
is closed.

`id`: The unique id for the peer that initiated the stream.
`stream`: A stream of requests associated with a single peer.
Handle all PeerHandlerRequests for a peer removing the peer after the request stream is closed . ` id ` : The unique id for the peer that initiated the stream . ` stream ` : A stream of requests associated with a single peer .
async fn manage_peer(mut self, id: PeerId, mut stream: PeerHandlerRequestStream) {
        while let Some(Ok(request)) = stream.next().await {
            if let Err(e) = self.handle_peer_request(id, request).await {
                fx_log_err!("{}", e);
                break;
            };
        }
        self.inner.lock().await.peers.remove(&id);
    }
async fn manage_peer ( mut self , id : PeerId , mut stream : PeerHandlerRequestStream ) { while let Some ( Ok ( request ) ) = stream . next ( ) . await { if let Err ( e ) = self . handle_peer_request ( id , request ) . await { fx_log_err ! ( " " e ) ; break ; } ; } self . inner . lock ( ) . await . peers . remove ( & id ) ; }
Handle all PeerHandlerRequests for a peer, removing the peer after the request stream
is closed.
Handle all PeerHandlerRequests for a peer removing the peer after the request stream is closed .
mut self
id
PeerId
stream
PeerHandlerRequestStream
mut self
id
PeerId
stream
PeerHandlerRequestStream