inline List extension executor

himadieievsv · Jan 17, 2024 · ea6bddf · ea6bddf
1 parent b1dd38c
commit ea6bddf
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/build.gradle.kts b/build.gradle.kts
@@ -18,7 +18,7 @@ plugins {
 
 allprojects {
     group = "com.himadieiev"
-    version = "1.1.4"
+    version = "1.1.5"
 
     repositories {
         mavenCentral()

diff --git a/...e/src/main/kotlin/com/himadieiev/redpulsar/core/locks/excecutors/MultiInstanceExecutor.kt b/...e/src/main/kotlin/com/himadieiev/redpulsar/core/locks/excecutors/MultiInstanceExecutor.kt
@@ -115,15 +115,15 @@ suspend inline fun <T : Backend, R> multiInstanceExecuteWithRetry(
     }
 }
 
-suspend fun <T : Backend, R> List<T>.executeWithRetry(
+suspend inline fun <T : Backend, R> List<T>.executeWithRetry(
     scope: CoroutineScope,
     timeout: Duration,
     defaultDrift: Duration = Duration.ofMillis(3),
     retryCount: Int = 3,
     retryDelay: Duration = Duration.ofMillis(100),
-    cleanUp: (backend: T) -> Unit = { _ -> },
     waitStrategy: WaitStrategy = WaitStrategy.ALL,
-    callee: suspend (backend: T) -> R,
+    crossinline cleanUp: (backend: T) -> Unit = { _ -> },
+    crossinline callee: suspend (backend: T) -> R,
 ): List<R> {
     return multiInstanceExecuteWithRetry(
         backends = this,