kylefang/gaze-indexer
1
0
Fork 0
mirror of https://github.com/alexgo-io/gaze-indexer.git synced 2026-04-30 04:35:13 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: reduce chunk size

Browse Source
This commit is contained in:
Gaze
2024-04-17 16:15:46 +07:00
parent 9ea39a72a5
commit d316950098
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
core/datasources/bitcoin_node.go
View File

@@ -141,7 +141,7 @@ func (d *BitcoinNodeDatasource) FetchAsync(ctx context.Context, from, to int64,
go func() {
defer stream.Close()
done := subscription.Done()
chunks := lo.Chunk(blockHeights, 100)
chunks := lo.Chunk(blockHeights, 10)
for _, chunk := range chunks {
chunk := chunk
select {