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) }