File tree Expand file tree Collapse file tree 3 files changed +9
-6
lines changed
krpc/krpc-ktor/krpc-ktor-client
src/commonMain/kotlin/kotlinx/rpc/krpc/ktor/client Expand file tree Collapse file tree 3 files changed +9
-6
lines changed Original file line number Diff line number Diff line change @@ -13,7 +13,8 @@ public final class kotlinx/rpc/krpc/ktor/client/KtorClientDslKt {
13
13
public static synthetic fun rpcConfig$default (Lio/ktor/client/request/HttpRequestBuilder;Lkotlin/jvm/functions/Function1;ILjava/lang/Object;)V
14
14
}
15
15
16
- public abstract interface class kotlinx/rpc/krpc/ktor/client/KtorRpcClient : kotlinx/rpc/RpcClient {
16
+ public abstract class kotlinx/rpc/krpc/ktor/client/KtorRpcClient : kotlinx/rpc/krpc/client/KrpcClient {
17
+ public fun <init> ()V
17
18
public abstract fun getWebSocketSession ()Lkotlinx/coroutines/Deferred;
18
19
}
19
20
Original file line number Diff line number Diff line change 6
6
// - Show declarations: true
7
7
8
8
// Library unique name: <org.jetbrains.kotlinx:krpc-ktor-client>
9
- abstract interface kotlinx.rpc.krpc.ktor.client/KtorRpcClient : kotlinx.rpc/RpcClient { // kotlinx.rpc.krpc.ktor.client/KtorRpcClient|null[0]
9
+ abstract class kotlinx.rpc.krpc.ktor.client/KtorRpcClient : kotlinx.rpc.krpc.client/KrpcClient { // kotlinx.rpc.krpc.ktor.client/KtorRpcClient|null[0]
10
+ constructor <init>() // kotlinx.rpc.krpc.ktor.client/KtorRpcClient.<init>|<init>(){}[0]
11
+
10
12
abstract val webSocketSession // kotlinx.rpc.krpc.ktor.client/KtorRpcClient.webSocketSession|{}webSocketSession[0]
11
13
abstract fun <get-webSocketSession>(): kotlinx.coroutines/Deferred<io.ktor.websocket/WebSocketSession> // kotlinx.rpc.krpc.ktor.client/KtorRpcClient.webSocketSession.<get-webSocketSession>|<get-webSocketSession>(){}[0]
12
14
}
Original file line number Diff line number Diff line change 1
1
/*
2
- * Copyright 2023-2024 JetBrains s.r.o and contributors. Use of this source code is governed by the Apache 2.0 license.
2
+ * Copyright 2023-2025 JetBrains s.r.o and contributors. Use of this source code is governed by the Apache 2.0 license.
3
3
*/
4
4
5
5
package kotlinx.rpc.krpc.ktor.client
@@ -22,19 +22,19 @@ import kotlinx.rpc.krpc.rpcClientConfig
22
22
* Client is cold, meaning the connection will be established on the first request.
23
23
* [webSocketSession] will be completed when the connection is established.
24
24
*/
25
- public interface KtorRpcClient : RpcClient {
25
+ public abstract class KtorRpcClient : KrpcClient () {
26
26
/* *
27
27
* Cold [WebSocketSession] object. Instantiated when the connection is established on the first request.
28
28
*/
29
- public val webSocketSession: Deferred <WebSocketSession >
29
+ public abstract val webSocketSession: Deferred <WebSocketSession >
30
30
}
31
31
32
32
internal class KtorKrpcClientImpl (
33
33
private val pluginConfigBuilder : KrpcConfigBuilder .Client ? ,
34
34
private val webSocketSessionFactory : suspend (
35
35
configSetter: (KrpcConfigBuilder .Client .() -> Unit ) -> Unit ,
36
36
) -> WebSocketSession ,
37
- ): KrpcClient(), KtorRpcClient {
37
+ ): KtorRpcClient() {
38
38
private var requestConfigBuilder: KrpcConfigBuilder .Client .() -> Unit = {}
39
39
40
40
private val _webSocketSession = CompletableDeferred <WebSocketSession >()
You can’t perform that action at this time.
0 commit comments