@@ -40,6 +40,12 @@ pub struct MessageId(pub PubsubMessageId);
4040pub struct HermesIpfsBuilder < N > ( IpfsBuilder < N > )
4141where N : NetworkBehaviour < ToSwarm = Infallible > + Send + Sync ;
4242
43+ impl Default for HermesIpfsBuilder < dummy:: Behaviour > {
44+ fn default ( ) -> Self {
45+ Self ( IpfsBuilder :: new ( ) )
46+ }
47+ }
48+
4349impl < N > HermesIpfsBuilder < N >
4450where N : NetworkBehaviour < ToSwarm = Infallible > + Send + Sync
4551{
@@ -591,7 +597,7 @@ impl FromStr for GetIpfsFile {
591597 }
592598}
593599
594- /// GossipsubEvents related to subscription state
600+ /// ` GossipsubEvents` related to subscription state
595601#[ derive( Display , Debug ) ]
596602pub enum SubscriptionStatusEvent {
597603 /// Peer has been subscribed
@@ -621,13 +627,13 @@ where
621627 while let Some ( msg) = stream. next ( ) . await {
622628 match msg {
623629 connexa:: prelude:: GossipsubEvent :: Subscribed { peer_id } => {
624- subscription_handler ( SubscriptionStatusEvent :: Subscribed { peer_id } )
630+ subscription_handler ( SubscriptionStatusEvent :: Subscribed { peer_id } ) ;
625631 } ,
626632 connexa:: prelude:: GossipsubEvent :: Unsubscribed { peer_id } => {
627- subscription_handler ( SubscriptionStatusEvent :: Unsubscribed { peer_id } )
633+ subscription_handler ( SubscriptionStatusEvent :: Unsubscribed { peer_id } ) ;
628634 } ,
629635 connexa:: prelude:: GossipsubEvent :: Message { message } => message_handler ( message) ,
630- } ;
636+ }
631637 }
632638 } )
633639}
0 commit comments