From 2f703edd1223fde6f4c893db1d4359d92e444845 Mon Sep 17 00:00:00 2001 From: Balint Gabor Date: Fri, 12 Jan 2018 20:10:38 +0100 Subject: [PATCH] swarm/network: Add missing RetrieveRequestMsg in spec in and handler --- swarm/network/streamer.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/swarm/network/streamer.go b/swarm/network/streamer.go index 72801d5a08..1e78a49adf 100644 --- a/swarm/network/streamer.go +++ b/swarm/network/streamer.go @@ -643,6 +643,7 @@ var StreamerSpec = &protocols.Spec{ WantedHashesMsg{}, TakeoverProofMsg{}, SubscribeMsg{}, + RetrieveRequestMsg{}, }, } @@ -685,6 +686,9 @@ func (self *StreamerPeer) HandleMsg(msg interface{}) error { case *ChunkDeliveryMsg: return self.handleChunkDeliveryMsg(msg) + case *RetrieveRequestMsg: + return self.handleRetrieveRequestMsg(msg) + default: return fmt.Errorf("unknown message type: %T", msg) }