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 {