diff --git a/blocks/blockstore/blockstore.go b/blocks/blockstore/blockstore.go index 477141cd62c..605be2bd867 100644 --- a/blocks/blockstore/blockstore.go +++ b/blocks/blockstore/blockstore.go @@ -196,7 +196,7 @@ func (bs *blockstore) AllKeysChan(ctx context.Context) (<-chan key.Key, error) { } } - output := make(chan key.Key) + output := make(chan key.Key, dsq.KeysOnlyBufSize) go func() { defer func() { res.Process().Close() // ensure exit (signals early exit, too)