minor fix

This commit is contained in:
ryanzhao
2021-05-28 15:14:05 +10:00
parent 4f7d26d86e
commit e8c52961aa
3 changed files with 8 additions and 3 deletions

View File

@@ -183,7 +183,10 @@ object SnodeAPI {
)
val promises = (1..validationCount).map {
getRandomSnode().bind { snode ->
invoke(Snode.Method.OxenDaemonRPCCall, snode, null, parameters)
retryIfNeeded(maxRetryCount) {
invoke(Snode.Method.OxenDaemonRPCCall, snode, null, parameters)
}
}
}
all(promises).success { results ->