build.gradle -> build.gradle.kts

build.gradle.kts

@@ -0,0 +1,26 @@
+plugins {
+    kotlin("jvm") version "2.0.20"
+    id("org.jetbrains.dokka") version "1.9.20"
+}
+
+allprojects {
+    group = "com.lightstreamer"
+    version = "0.1.0"
+
+    repositories {
+        mavenCentral()
+    }
+}
+
+subprojects {
+    apply(plugin = "kotlin")
+    apply(plugin = "maven-publish")
+    apply(plugin = "org.jetbrains.dokka")
+
+    version = parent?.version ?: error("Parent version not found")
+
+    kotlin {
+        explicitApi()
+        jvmToolchain(21)
+    }
+}

client/build.gradle.kts

@@ -0,0 +1,12 @@
+description = "Lightstreamer client"
+
+dependencies {
+    api(project(":ls-kotlin-mini-socket"))
+    testImplementation(kotlin("test"))
+    testApi("org.slf4j:slf4j-simple:1.7.36")
+    testApi("org.amshove.kluent:kluent:1.73")
+}
+
+tasks.test {
+    useJUnitPlatform()
+}

client/src/main/kotlin/com/lightstreamer/client/internal/LightstreamerSessionImpl.kt

@@ -78,12 +78,12 @@ internal class LightstreamerSessionImpl(
                     if (lightstreamerServerException != null)
                         return@runCatching lightstreamerServerException
                 }
-                null
+                return@runCatching null
             }
 
             exitResult
-                .onSuccess { completableExitStatus.complete(it) }
-                .onFailure { completableExitStatus.completeExceptionally(it) }
+                .onSuccess(completableExitStatus::complete)
+                .onFailure(completableExitStatus::completeExceptionally)
 
             // cancel pending tasks
             val cause =
@@ -232,11 +232,8 @@ internal class LightstreamerSessionImpl(
                             val serverMessage =
                                 if (keepAlive == null) socket.receive()
                                 else withTimeout(keepAlive.inWholeMilliseconds.coerceAtLeast(1)) { socket.receive() }
-                            if (serverMessage.isDataNotification()) {
-                                messageToSkip--
-                            } else {
-                                onServerMessage(serverMessage)
-                            }
+                            if (serverMessage.isDataNotification()) messageToSkip--
+                            else onServerMessage(serverMessage)
                         }
 
                         connectionOk

socket/build.gradle.kts

@@ -0,0 +1,13 @@
+description = "TLCP parser"
+
+dependencies {
+    api("org.jetbrains.kotlinx:kotlinx-coroutines-core-jvm:1.9.0")
+    api("io.github.microutils:kotlin-logging-jvm:3.0.5")
+    testImplementation(kotlin("test"))
+    testApi("ch.qos.logback:logback-classic:1.2.13")
+    testApi("org.amshove.kluent:kluent:1.73")
+}
+
+tasks.test {
+    useJUnitPlatform()
+}