From dc134e0219814e4dcf13879753ef692c4e79c0d8 Mon Sep 17 00:00:00 2001 From: Balint Gabor Date: Fri, 12 Jan 2018 20:24:45 +0100 Subject: [PATCH] swarm/network: Store stream in outgoingStreamer --- swarm/network/streamer.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/swarm/network/streamer.go b/swarm/network/streamer.go index 7911161452..365222ab17 100644 --- a/swarm/network/streamer.go +++ b/swarm/network/streamer.go @@ -203,6 +203,7 @@ type outgoingStreamer struct { OutgoingStreamer priority uint8 currentBatch []byte + stream string } // OutgoingStreamer interface for outgoing peer Streamer @@ -640,6 +641,9 @@ func (self *StreamerPeer) SendOfferedHashes(s *outgoingStreamer, f, t uint64) er Hashes: hashes, From: from, To: to, + Stream: s.stream, + // TODO: use real key here + Key: []byte{}, } return self.SendPriority(msg, s.priority) }