Restructuring p2p handlers (#1702)

NethermindEth · Apr 30, 2024 · efa8774 · efa8774
1 parent 72dfa3a
commit efa8774
Show file tree

Hide file tree

Showing 2 changed files with 173 additions and 135 deletions.
diff --git a/p2p/p2p.go b/p2p/p2p.go
@@ -336,13 +336,8 @@ func (s *Service) SubscribeToTopic(topic string) (chan []byte, func(), error) {
 }
 
 func (s *Service) PublishOnTopic(topic string) error {
-	t, joinErr := s.joinTopic(topic)
-	if joinErr != nil {
-		return joinErr
-	}
-	_ = t
-
-	return nil
+	_, err := s.joinTopic(topic)
+	return err
 }
 
 func (s *Service) SetProtocolHandler(pid protocol.ID, handler func(network.Stream)) {