forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-19 18:32:23 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

swarm/network/stream: assign error and check in one line

Browse source
This commit is contained in:
Attila Gazso 2018-10-14 11:28:58 +02:00
parent ad550ae3e1
commit cf4bac4a15
1 changed files with 1 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
swarm/network/stream/messages.go
View file

@ -76,8 +76,7 @@ type RequestSubscriptionMsg struct {
func (p *Peer) handleRequestSubscription(ctx context.Context, req *RequestSubscriptionMsg) (err error) { func (p *Peer) handleRequestSubscription(ctx context.Context, req *RequestSubscriptionMsg) (err error) {
log.Debug(fmt.Sprintf("handleRequestSubscription: streamer %s to subscribe to %s with stream %s", p.streamer.addr, p.ID(), req.Stream)) log.Debug(fmt.Sprintf("handleRequestSubscription: streamer %s to subscribe to %s with stream %s", p.streamer.addr, p.ID(), req.Stream))
err = p.streamer.Subscribe(p.ID(), req.Stream, req.History, req.Priority) if err = p.streamer.Subscribe(p.ID(), req.Stream, req.History, req.Priority); err != nil {
if err != nil {
// The error will be sent as a subscribe error message // The error will be sent as a subscribe error message
// and will not be returned as it will prevent any new message // and will not be returned as it will prevent any new message
// exchange between peers over p2p. Instead, error will be returned // exchange between peers over p2p. Instead, error will be returned