Checkpoint.

License: MIT
Signed-off-by: Kevin Atkinson <k@kevina.org>

blocks/blockstore/blockstore.go

@@ -186,8 +186,9 @@ func (bs *blockstore) AllKeysChan(ctx context.Context) (<-chan *cid.Cid, error)
 		select {
 		case <-ctx.Done():
 			return nil, false
-		case e, more := <-res.Next():
-			if !more {
+		default:
+			e, ok := res.NextSync()
+			if !ok {
 				return nil, false
 			}
 			if e.Error != nil {
@@ -209,7 +210,7 @@ func (bs *blockstore) AllKeysChan(ctx context.Context) (<-chan *cid.Cid, error)
 	output := make(chan *cid.Cid, dsq.KeysOnlyBufSize)
 	go func() {
 		defer func() {
-			res.Process().Close() // ensure exit (signals early exit, too)
+			res.Close() // ensure exit (signals early exit, too)
 			close(output)
 		}()