diktat fixes

icemachined · Oct 25, 2023 · 83b1710 · 83b1710
1 parent d54dd98
commit 83b1710
Show file tree

Hide file tree

Showing 5 changed files with 11 additions and 16 deletions.
diff --git a/buildSrc/src/main/kotlin/com/icemachined/buildutils/kotlin-library.gradle.kts b/buildSrc/src/main/kotlin/com/icemachined/buildutils/kotlin-library.gradle.kts
@@ -41,7 +41,7 @@ kotlin {
         else -> throw GradleException("Host OS is not supported in Kotlin/Native.")
     }
 
-    val targetNames = nativeTargets.map{ it.name }.filter { !currentTargetName.equals(it) }.toList()
+    val targetNames = nativeTargets.map { it.name }.filterNot { it == currentTargetName }.toList()
     tasks.matching { task ->
         !(targetNames.find {
             task.name.contains(it, true)

diff --git a/kafka-client-test/build.gradle.kts b/kafka-client-test/build.gradle.kts
@@ -59,10 +59,11 @@ fun linkProperExecutable(os: org.gradle.nativeplatform.platform.internal.Default
         os.isLinux -> tasks.getByName("linkReleaseExecutableLinuxX64")
         os.isWindows -> tasks.getByName("linkReleaseExecutableMingwX64")
         os.isMacOsX ->
-            if (getCurrentArchitecture().isArm)
+            if (getCurrentArchitecture().isArm) {
                 tasks.getByName("linkReleaseExecutableMacosArm64")
-            else
+            } else {
                 tasks.getByName("linkReleaseExecutableMacosX64")
+            }
         else -> throw GradleException("Unknown operating system $os")
     }
     project.tasks.register("linkReleaseExecutableMultiplatform") {

diff --git a/kafka-client/build.gradle.kts b/kafka-client/build.gradle.kts
@@ -18,8 +18,6 @@ kotlin {
         else -> throw GradleException("Host OS is not supported in Kotlin/Native.")
     }
 
-    println("nativeTarget = ${nativeTarget.name}")
-
     nativeTarget.apply {
         compilations.getByName("main") {
             cinterops {

diff --git a/kafka-client/src/nativeMain/kotlin/com/icemachined/kafka/clients/KafkaUtils.kt b/kafka-client/src/nativeMain/kotlin/com/icemachined/kafka/clients/KafkaUtils.kt
@@ -10,15 +10,12 @@
 package com.icemachined.kafka.clients
 
 import com.icemachined.kafka.common.*
-
+import kotlinx.cinterop.*
+import kotlinx.coroutines.delay
 import librdkafka.*
 import platform.posix.size_t
 import platform.posix.stdout
 
-import kotlin.native.concurrent.freeze
-import kotlinx.cinterop.*
-import kotlinx.coroutines.delay
-
 typealias KafkaNativeProperties = Map<String, String>
 
 /**

diff --git a/kafka-client/src/nativeMain/kotlin/com/icemachined/kafka/clients/consumer/KafkaConsumer.kt b/kafka-client/src/nativeMain/kotlin/com/icemachined/kafka/clients/consumer/KafkaConsumer.kt
@@ -367,12 +367,11 @@ internal fun rebalanceCallback(
         }
     }
 
-    error?.let {
-        logError("rebalanceCallback", "incremental assign failure: ${rd_kafka_error_string(it)?.toKString()}")
-        rd_kafka_error_destroy(it)
-    } ?: if (returnError != RD_KAFKA_RESP_ERR_NO_ERROR) {
+    if (error != null) {
+        logError("rebalanceCallback", "incremental assign failure: ${rd_kafka_error_string(error)?.toKString()}")
+        rd_kafka_error_destroy(error)
+    } else if (returnError != RD_KAFKA_RESP_ERR_NO_ERROR) {
         logError("rebalanceCallback", "assign failure: ${rd_kafka_err2str(returnError)?.toKString()}")
-    } else {
-
     }
+
 }