Fixed subscribe

Author: jgraef

network-libp2p/src/network.rs

@@ -306,7 +306,7 @@ impl Network {
                                 for topic in msg.topics.iter() {
                                     if let Some(output) = state.gossip_topics.get(&topic) {
                                         // let peer = Self::get_peer(peer_id).unwrap();
-                                        // output.send((msg, peer));
+                                        output.send((msg, peer));
                                     } else {
                                         log::warn!("Unknown topic hash: {:?}", topic);
                                     }
@@ -436,12 +436,10 @@ impl NetworkInterface for Network {
             })
             .await;
 
-        let test = rx.map(|(msg, peer)|
-            {
-                let item = msg.data;
-                ( item , peer) 
-            }).into_inner();
-        Box::new(test)
+        Box::new(rx.map(|(msg, peer)| {
+            let item: <T as Topic>::Item = Deserialize::deserialize_from_vec(&msg.data);
+            (item, peer)
+        }))
     }
 
     async fn publish<T>(&self, topic: &T, item: <T as Topic>::Item) -> Result<(), Self::Error>