review: iodiomatic usage of stream

node/src/endpoint_gossip/rpc/state.rs

@@ -52,10 +52,11 @@ impl DuniterPeeringsState {
 
     /// Creates a channel for binding to the network events.
     pub fn listen(&self) -> TracingUnboundedSender<DuniterPeeringEvent> {
-        let (sink, mut stream) = tracing_unbounded("mpsc_duniter_peering_rpc_stream", 1_000);
+        let (sink, stream) = tracing_unbounded("mpsc_duniter_peering_rpc_stream", 1_000);
         let state = self.clone();
         tokio::spawn(async move {
-            while let Some(event) = stream.next().await {
+            stream
+                .for_each(|event| async {
                     match event {
                         DuniterPeeringEvent::GoodPeering(who, peering) => {
                             state.insert(PeeringWithId {
@@ -68,7 +69,8 @@ impl DuniterPeeringsState {
                         }
                         _ => {}
                     }
-            }
+                })
+                .await
         });
         sink
     }