close keys channel when dome emitting keys

2020-11-25 09:07:06 +02:00 · 2020-11-25 09:07:06 +02:00 · 101e5c6540
commit 101e5c6540
parent b945747eb2
1 changed files with 1 additions and 0 deletions
--- 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 {