Use a for loop for getting diffs off the payload channel

2019-07-22 16:48:18 -05:00 · 2019-07-22 16:48:18 -05:00 · 7cd66b8775
commit 7cd66b8775
parent 7cbad1d89f
1 changed files with 2 additions and 1 deletions
--- 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 {