diff --git a/swarm/network/stream/stream.go b/swarm/network/stream/stream.go index ea19d28f05..5770f679c3 100644 --- a/swarm/network/stream/stream.go +++ b/swarm/network/stream/stream.go @@ -298,6 +298,7 @@ type client struct { type Client interface { NeedData([]byte) func() BatchDone(string, uint64, []byte, []byte) func() (*TakeoverProof, error) + Close() } // nextBatch adjusts the indexes by inspecting the intervals @@ -344,6 +345,7 @@ func (c *client) batchDone(p *Peer, req *OfferedHashesMsg, hashes []byte) error func (c *client) close() { close(c.next) + c.Close() } // Spec is the spec of the streamer protocol diff --git a/swarm/network/stream/syncer.go b/swarm/network/stream/syncer.go index 2369a2ae5f..6d8473afc9 100644 --- a/swarm/network/stream/syncer.go +++ b/swarm/network/stream/syncer.go @@ -253,3 +253,5 @@ func (s *SwarmSyncerClient) TakeoverProof(streamName string, from uint64, hashes Sig: nil, }, nil } + +func (s *SwarmSyncerClient) Close() {}