network/stream: terminate runUpdateSyncing on peer quit (ethersphere#1696)

janos · acud · commit e821eb4ba09b · 2019-08-28T14:53:52.000+05:30
diff --git a/network/stream/peer.go b/network/stream/peer.go
@@ -451,6 +451,8 @@ func (p *Peer) runUpdateSyncing() {
 			prevDepth = depth
 		case <-p.streamer.quit:
 			return
+		case <-p.quit:
+			return
 		}
 	}
 }

Original file line number	Diff line number	Diff line change
`@@ -451,6 +451,8 @@ func (p *Peer) runUpdateSyncing() {`
`451`	`451`	`prevDepth = depth`
`452`	`452`	`case <-p.streamer.quit:`
`453`	`453`	`return`
	`454`	`+ case <-p.quit:`
	`455`	`+ return`
`454`	`456`	`}`
`455`	`457`	`}`
`456`	`458`	`}`