stream: dereference StreamInfoReq structure in updateSyncSubscription…

…s function (#1770)
ethersphere · Sep 17, 2019 · 5824b64 · 5824b64
1 parent 1456b9f
commit 5824b64
Showing 1 changed file with 1 addition and 1 deletion.
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