some updates to pubsub

src/p2p/behaviour.rs

@@ -15,6 +15,7 @@ use libp2p::kad::{Kademlia, KademliaConfig, KademliaEvent, Quorum};
 // use libp2p::mdns::{MdnsEvent, TokioMdns};
 use libp2p::ping::{Ping, PingEvent};
 // use libp2p::swarm::toggle::Toggle;
+use libp2p::floodsub::FloodsubEvent;
 use libp2p::swarm::{NetworkBehaviour, NetworkBehaviourEventProcess};
 use multibase::Base;
 use std::{convert::TryInto, sync::Arc};
@@ -43,6 +44,7 @@ pub enum BehaviourEvent {
  Ping(PingEvent),
  Identify(IdentifyEvent),
  Bitswap(BitswapEvent),
+ Floodsub(FloodsubEvent),
  Void,
 }
 
@@ -70,6 +72,12 @@ impl From<BitswapEvent> for BehaviourEvent {
  }
 }
 
+impl From<FloodsubEvent> for BehaviourEvent {
+ fn from(event: FloodsubEvent) -> Self {
+ Self::Floodsub(event)
+ }
+}
+
 impl From<void::Void> for BehaviourEvent {
  fn from(_void: void::Void) -> Self {
  Self::Void

src/p2p/pubsub.rs

@@ -243,7 +243,7 @@ type PubsubNetworkBehaviourAction = NetworkBehaviourAction<
 
 impl NetworkBehaviour for Pubsub {
  type ConnectionHandler = <Floodsub as NetworkBehaviour>::ConnectionHandler;
- type OutEvent = void::Void;
+ type OutEvent = FloodsubEvent;
 
  fn new_handler(&mut self) -> Self::ConnectionHandler {
  self.floodsub.new_handler()