altavir/kotlin-full-stack-demo
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Update the project to a modern state

Browse Source
This commit is contained in:
Alexander Nozik 2024-04-28 19:18:06 +03:00
parent 871e70222d
commit 31a9231bb8
2 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/jsMain/kotlin/client.kt
View File

@ -57,8 +57,8 @@ suspend fun main() {
LaunchedEffect(Unit){ LaunchedEffect(Unit){
dataFlow.onEach { event -> dataFlow.onEach { event ->
println("Received $event") println("Received $event")
if (event is CounterDataEvent) { when (event) {
count = event.value is CounterDataEvent -> count = event.value
} }
}.launchIn(this) }.launchIn(this)
} }

4
src/jvmMain/kotlin/server.kt
View File

@ -5,7 +5,6 @@ import io.ktor.server.application.call
import io.ktor.server.application.install import io.ktor.server.application.install
import io.ktor.server.engine.embeddedServer import io.ktor.server.engine.embeddedServer
import io.ktor.server.html.respondHtml import io.ktor.server.html.respondHtml
import io.ktor.server.http.content.resources
import io.ktor.server.http.content.staticResources import io.ktor.server.http.content.staticResources
import io.ktor.server.netty.Netty import io.ktor.server.netty.Netty
import io.ktor.server.routing.get import io.ktor.server.routing.get
@ -19,7 +18,6 @@ import io.rsocket.kotlin.payload.buildPayload
import io.rsocket.kotlin.payload.data import io.rsocket.kotlin.payload.data
import kotlinx.coroutines.flow.* import kotlinx.coroutines.flow.*
import kotlinx.html.* import kotlinx.html.*
import kotlinx.serialization.decodeFromString
import kotlinx.serialization.encodeToString import kotlinx.serialization.encodeToString
import kotlinx.serialization.json.Json import kotlinx.serialization.json.Json
@ -63,7 +61,7 @@ fun main() {
get("/") { get("/") {
call.respondHtml(HttpStatusCode.OK, HTML::index) call.respondHtml(HttpStatusCode.OK, HTML::index)
} }
staticResources("/","www") staticResources("/", "www")
rSocket("rsocket") { rSocket("rsocket") {
println(config.setupPayload.data.readText()) //print setup payload data println(config.setupPayload.data.readText()) //print setup payload data