We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 97a55c7 commit 2d872a1Copy full SHA for 2d872a1
scalanet/discovery/src/io/iohk/scalanet/discovery/ethereum/v4/DiscoveryService.scala
@@ -815,7 +815,7 @@ object DiscoveryService {
815
val tryEnroll = for {
816
nodeId <- stateRef.get.map(_.node.id)
817
bootstrapPeers = config.knownPeers.toList.map(toPeer).filterNot(_.id == nodeId)
818
- maybeBootstrapEnrs <- bootstrapPeers.traverse(fetchEnr(_, delay = true))
+ maybeBootstrapEnrs <- Task.parTraverseN(config.kademliaAlpha)(bootstrapPeers)(fetchEnr(_, delay = true))
819
result <- if (maybeBootstrapEnrs.exists(_.isDefined)) {
820
lookup(nodeId).as(true)
821
} else {
0 commit comments