From 7cd66b877592c22e653b6d97d62a56d4dd690583 Mon Sep 17 00:00:00 2001 From: Elizabeth Engelman Date: Mon, 22 Jul 2019 16:48:18 -0500 Subject: [PATCH] Use a for loop for getting diffs off the payload channel --- libraries/shared/fetcher/geth_rpc_storage_fetcher.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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 {