stream: dereference StreamInfoReq structure in updateSyncSubscriptions function (ethersphere#1770)

mortelli · zelig · commit 5824b649a30f · 2019-09-17T23:33:44.000+02:00
diff --git a/network/stream/v2/sync_provider.go b/network/stream/v2/sync_provider.go
@@ -334,7 +334,7 @@ func (s *syncProvider) updateSyncSubscriptions(p *Peer, subBins, quitBins []int)
 		}
 		ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
 		defer cancel()
-		if err := p.Send(ctx, StreamInfoReq{Streams: streams}); err != nil {
+		if err := p.Send(ctx, &StreamInfoReq{Streams: streams}); err != nil {
 			p.logger.Error("error establishing subsequent subscription", "err", err)
 			p.Drop()
 			return

Original file line number	Diff line number	Diff line change
`@@ -334,7 +334,7 @@ func (s syncProvider) updateSyncSubscriptions(p Peer, subBins, quitBins []int)`
`334`	`334`	`}`
`335`	`335`	`ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)`
`336`	`336`	`defer cancel()`
`337`		`- if err := p.Send(ctx, StreamInfoReq{Streams: streams}); err != nil {`
	`337`	`+ if err := p.Send(ctx, &StreamInfoReq{Streams: streams}); err != nil {`
`338`	`338`	`p.logger.Error("error establishing subsequent subscription", "err", err)`
`339`	`339`	`p.Drop()`
`340`	`340`	`return`