From 101e5c6540ce8265b7730b518ee82a9f99da3b09 Mon Sep 17 00:00:00 2001 From: vyzo Date: Wed, 25 Nov 2020 09:07:06 +0200 Subject: [PATCH] close keys channel when dome emitting keys --- chain/store/splitstore.go | 1 + 1 file changed, 1 insertion(+) diff --git a/chain/store/splitstore.go b/chain/store/splitstore.go index 1a69abf50..42e2f132e 100644 --- a/chain/store/splitstore.go +++ b/chain/store/splitstore.go @@ -145,6 +145,7 @@ func (s *SplitStore) AllKeysChan(ctx context.Context) (<-chan cid.Cid, error) { ch := make(chan cid.Cid) go func() { defer cancel() + defer close(ch) for _, in := range []<-chan cid.Cid{chHot, chCold} { for cid := range in {