Commit c12d54cb authored by Kevin Atkinson's avatar Kevin Atkinson

Increase channel buffer size in blockstore.AllKeysChan().

License: MIT
Signed-off-by: default avatarKevin Atkinson <k@kevina.org>
parent aa8ea8f7
......@@ -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)
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment