mirrors/bitcoin-s
1
0
Fork 0
mirror of https://github.com/bitcoin-s/bitcoin-s.git synced 2025-01-19 05:43:51 +01:00
Code Issues Packages Projects Releases Wiki Activity

Implement batchAndParallelExecute with Future.traverse rather than Future.sequence (#5051)

Browse Source
This commit is contained in:
Chris Stewart 2023-04-20 17:59:09 -05:00 committed by GitHub
parent 5f9c89820f
commit 3740b4fc35
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
core/src/main/scala/org/bitcoins/core/util/FutureUtil.scala
View File

@ -122,9 +122,8 @@ object FutureUtil {
Future.successful(Vector.empty)
} else {
val batches = elements.grouped(batchSize).toVector
val execute: Vector[Future[U]] = batches.map(b => f(b))
val doneF = Future.sequence(execute)
doneF
val executeF: Future[Vector[U]] = Future.traverse(batches)(f(_))
executeF
}
}