We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a5e45ee commit db0d7a6Copy full SHA for db0d7a6
rsocket-core/src/commonMain/kotlin/io/rsocket/kotlin/connection/KeepAliveHandler.kt
@@ -17,6 +17,7 @@
17
package io.rsocket.kotlin.connection
18
19
import io.rsocket.kotlin.*
20
+import io.rsocket.kotlin.frame.io.*
21
import io.rsocket.kotlin.keepalive.*
22
import kotlinx.atomicfu.*
23
import kotlinx.coroutines.*
@@ -41,9 +42,7 @@ internal class KeepAliveHandler(
41
42
if (currentDelayMillis() - lastMark.value >= keepAlive.maxLifetimeMillis)
43
throw RSocketError.ConnectionError("No keep-alive for ${keepAlive.maxLifetimeMillis} ms")
44
- outbound.sendKeepAlive(true, Buffer().apply {
45
- writeString(currentDelayMillis().toString())
46
- }, 0)
+ outbound.sendKeepAlive(true, EmptyBuffer, 0)
47
}
48
49
0 commit comments