diff --git a/libraries/shared/fetcher/geth_rpc_storage_fetcher.go b/libraries/shared/fetcher/geth_rpc_storage_fetcher.go
index 1be67480..a8a7c5a4 100644
--- a/libraries/shared/fetcher/geth_rpc_storage_fetcher.go
+++ b/libraries/shared/fetcher/geth_rpc_storage_fetcher.go
@@ -41,7 +41,8 @@ func (fetcher *GethRpcStorageFetcher) FetchStorageDiffs(out chan<- utils.Storage
 		errs <- err
 	}
 
-	for diff := range ethStatediffPayloadChan {
+	for {
+		diff := <-ethStatediffPayloadChan
 		stateDiff := new(statediff.StateDiff)
 		err = rlp.DecodeBytes(diff.StateDiffRlp, stateDiff)
 		if err != nil {