swarm/network/stream: Simplify code (#303)

ethereum · Mar 6, 2018 · 5c57cba · 5c57cba
1 parent cdca257
commit 5c57cba
Showing 1 changed file with 1 addition and 5 deletions.
diff --git a/swarm/network/stream/messages.go b/swarm/network/stream/messages.go
@@ -71,11 +71,7 @@ type RequestSubscriptionMsg struct {
 
 func (p *Peer) handleRequestSubscription(req *RequestSubscriptionMsg) (err error) {
 	log.Debug(fmt.Sprintf("handleRequestSubscription: streamer %s to subscribe to %s with stream %s", p.streamer.addr.ID(), p.ID(), req.Stream))
-	err = p.streamer.Subscribe(p.ID(), req.Stream, req.History, req.Priority)
-	if err != nil {
-		return err
-	}
-	return nil
+	return p.streamer.Subscribe(p.ID(), req.Stream, req.History, req.Priority)
 }
 
 func (p *Peer) handleSubscribeMsg(req *SubscribeMsg) (err error) {