Skip to content

Commit 4c138ee

Browse files
whyolegwhyoleg
committed
update API dump
1 parent 9040db9 commit 4c138ee

File tree

6 files changed

+15
-24
lines changed

6 files changed

+15
-24
lines changed

‎rsocket-core/api/rsocket-core.api‎

Lines changed: 5 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -222,9 +222,9 @@ public final class io/rsocket/kotlin/core/RSocketConnectorBuilderKt {
222222
}
223223

224224
public final class io/rsocket/kotlin/core/RSocketServer {
225+
public final fun acceptConnection (Lio/rsocket/kotlin/ConnectionAcceptor;Lio/rsocket/kotlin/transport/RSocketConnection;)V
225226
public final fun bind (Lio/rsocket/kotlin/transport/ServerTransport;Lio/rsocket/kotlin/ConnectionAcceptor;)Ljava/lang/Object;
226227
public final fun bindIn (Lkotlinx/coroutines/CoroutineScope;Lio/rsocket/kotlin/transport/ServerTransport;Lio/rsocket/kotlin/ConnectionAcceptor;)Ljava/lang/Object;
227-
public final fun createHandler (Lio/rsocket/kotlin/ConnectionAcceptor;)Lio/rsocket/kotlin/transport/RSocketConnectionHandler;
228228
public final fun startServer (Lio/rsocket/kotlin/transport/RSocketServerTarget;Lio/rsocket/kotlin/ConnectionAcceptor;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
229229
}
230230

@@ -751,23 +751,18 @@ public final class io/rsocket/kotlin/transport/ClientTransportKt {
751751
}
752752

753753
public abstract interface class io/rsocket/kotlin/transport/RSocketClientTarget : kotlinx/coroutines/CoroutineScope {
754-
public abstract fun connectClient (Lio/rsocket/kotlin/transport/RSocketConnectionHandler;)Lkotlinx/coroutines/Job;
754+
public abstract fun connectClient (Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
755755
}
756756

757-
public abstract interface class io/rsocket/kotlin/transport/RSocketConnection {
758-
}
759-
760-
public abstract interface class io/rsocket/kotlin/transport/RSocketConnectionHandler {
761-
public abstract fun handleConnection (Lio/rsocket/kotlin/transport/RSocketConnection;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
757+
public abstract interface class io/rsocket/kotlin/transport/RSocketConnection : kotlinx/coroutines/CoroutineScope {
762758
}
763759

764760
public abstract interface class io/rsocket/kotlin/transport/RSocketMultiplexedConnection : io/rsocket/kotlin/transport/RSocketConnection {
765761
public abstract fun acceptStream (Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
766762
public abstract fun createStream (Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
767763
}
768764

769-
public abstract interface class io/rsocket/kotlin/transport/RSocketMultiplexedConnection$Stream : java/lang/AutoCloseable {
770-
public abstract fun close ()V
765+
public abstract interface class io/rsocket/kotlin/transport/RSocketMultiplexedConnection$Stream : kotlinx/coroutines/CoroutineScope {
771766
public abstract fun isClosedForSend ()Z
772767
public abstract fun receiveFrame (Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
773768
public abstract fun sendFrame (Lkotlinx/io/Buffer;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
@@ -784,7 +779,7 @@ public abstract interface class io/rsocket/kotlin/transport/RSocketServerInstanc
784779
}
785780

786781
public abstract interface class io/rsocket/kotlin/transport/RSocketServerTarget : kotlinx/coroutines/CoroutineScope {
787-
public abstract fun startServer (Lio/rsocket/kotlin/transport/RSocketConnectionHandler;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
782+
public abstract fun startServer (Lkotlin/jvm/functions/Function1;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
788783
}
789784

790785
public abstract interface class io/rsocket/kotlin/transport/RSocketTransport : kotlinx/coroutines/CoroutineScope {

‎rsocket-internal-io/api/rsocket-internal-io.api‎

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -7,8 +7,7 @@ public final class io/rsocket/kotlin/internal/io/ChannelsKt {
77
public final class io/rsocket/kotlin/internal/io/ContextKt {
88
public static final fun childContext (Lkotlin/coroutines/CoroutineContext;)Lkotlin/coroutines/CoroutineContext;
99
public static final fun ensureActive (Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm/functions/Function0;)V
10-
public static final fun launchCoroutine (Lkotlinx/coroutines/CoroutineScope;Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm/functions/Function2;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
11-
public static synthetic fun launchCoroutine$default (Lkotlinx/coroutines/CoroutineScope;Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm/functions/Function2;Lkotlin/coroutines/Continuation;ILjava/lang/Object;)Ljava/lang/Object;
10+
public static final fun nonCancellable (Lkotlin/jvm/functions/Function2;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
1211
public static final fun onCompletion (Lkotlinx/coroutines/Job;Lkotlin/jvm/functions/Function1;)Lkotlinx/coroutines/Job;
1312
public static final fun supervisorContext (Lkotlin/coroutines/CoroutineContext;)Lkotlin/coroutines/CoroutineContext;
1413
}

‎rsocket-transports/ktor-tcp/api/rsocket-transport-ktor-tcp.api‎

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -8,10 +8,7 @@ public final class io/rsocket/kotlin/transport/ktor/tcp/KtorTcpClientTransport$F
88
}
99

1010
public abstract interface class io/rsocket/kotlin/transport/ktor/tcp/KtorTcpClientTransportBuilder : io/rsocket/kotlin/transport/RSocketTransportBuilder {
11-
public abstract fun dispatcher (Lkotlin/coroutines/CoroutineContext;)V
12-
public fun inheritDispatcher ()V
1311
public abstract fun selectorManager (Lio/ktor/network/selector/SelectorManager;Z)V
14-
public abstract fun selectorManagerDispatcher (Lkotlin/coroutines/CoroutineContext;)V
1512
public abstract fun socketOptions (Lkotlin/jvm/functions/Function1;)V
1613
}
1714

@@ -31,10 +28,7 @@ public final class io/rsocket/kotlin/transport/ktor/tcp/KtorTcpServerTransport$F
3128
}
3229

3330
public abstract interface class io/rsocket/kotlin/transport/ktor/tcp/KtorTcpServerTransportBuilder : io/rsocket/kotlin/transport/RSocketTransportBuilder {
34-
public abstract fun dispatcher (Lkotlin/coroutines/CoroutineContext;)V
35-
public fun inheritDispatcher ()V
3631
public abstract fun selectorManager (Lio/ktor/network/selector/SelectorManager;Z)V
37-
public abstract fun selectorManagerDispatcher (Lkotlin/coroutines/CoroutineContext;)V
3832
public abstract fun socketOptions (Lkotlin/jvm/functions/Function1;)V
3933
}
4034

‎rsocket-transports/ktor-websocket-internal/api/rsocket-transport-ktor-websocket-internal.api‎

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,9 @@
1-
public final class io/rsocket/kotlin/transport/ktor/websocket/internal/KtorWebSocketConnectionKt {
2-
public static final fun handleKtorWebSocketConnection (Lio/rsocket/kotlin/transport/RSocketConnectionHandler;Lio/ktor/websocket/WebSocketSession;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
1+
public final class io/rsocket/kotlin/transport/ktor/websocket/internal/KtorWebSocketConnection : io/rsocket/kotlin/transport/RSocketSequentialConnection {
2+
public fun <init> (Lio/ktor/websocket/WebSocketSession;)V
3+
public fun getCoroutineContext ()Lkotlin/coroutines/CoroutineContext;
4+
public fun isClosedForSend ()Z
5+
public fun receiveFrame (Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
6+
public fun sendFrame (ILkotlinx/io/Buffer;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
37
}
48

59
public final class io/rsocket/kotlin/transport/ktor/websocket/internal/WebSocketConnection : io/rsocket/kotlin/Connection, kotlinx/coroutines/CoroutineScope {

‎rsocket-transports/local/api/rsocket-transport-local.api‎

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,6 @@ public final class io/rsocket/kotlin/transport/local/LocalClientTransport$Factor
88

99
public abstract interface class io/rsocket/kotlin/transport/local/LocalClientTransportBuilder : io/rsocket/kotlin/transport/RSocketTransportBuilder {
1010
public abstract fun dispatcher (Lkotlin/coroutines/CoroutineContext;)V
11-
public fun inheritDispatcher ()V
1211
}
1312

1413
public final class io/rsocket/kotlin/transport/local/LocalServer : io/rsocket/kotlin/transport/ClientTransport {
@@ -35,7 +34,6 @@ public final class io/rsocket/kotlin/transport/local/LocalServerTransport$Factor
3534

3635
public abstract interface class io/rsocket/kotlin/transport/local/LocalServerTransportBuilder : io/rsocket/kotlin/transport/RSocketTransportBuilder {
3736
public abstract fun dispatcher (Lkotlin/coroutines/CoroutineContext;)V
38-
public fun inheritDispatcher ()V
3937
public abstract fun multiplexed ()V
4038
public abstract fun sequential ()V
4139
}

‎rsocket-transports/netty-internal/api/rsocket-transport-netty-internal.api‎

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,12 @@
11
public final class io/rsocket/kotlin/transport/netty/internal/CoroutinesKt {
2-
public static final fun awaitChannel (Lio/netty/channel/ChannelFuture;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
32
public static final fun awaitFuture (Lio/netty/util/concurrent/Future;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
4-
public static final fun callOnCancellation (Lkotlinx/coroutines/CoroutineScope;Lkotlin/jvm/functions/Function1;)V
3+
public static final fun join (Lio/netty/util/concurrent/Future;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
4+
public static final fun shutdownOnCancellation (Lkotlinx/coroutines/CoroutineScope;[Lio/netty/channel/EventLoopGroup;)V
55
}
66

77
public final class io/rsocket/kotlin/transport/netty/internal/IoKt {
88
public static final fun toBuffer (Lio/netty/buffer/ByteBuf;)Lkotlinx/io/Buffer;
99
public static final fun toByteBuf (Lkotlinx/io/Buffer;Lio/netty/buffer/ByteBufAllocator;)Lio/netty/buffer/ByteBuf;
10+
public static final fun writeBuffer (Lio/netty/channel/Channel;Lkotlinx/io/Buffer;)V
1011
}
1112

0 commit comments

Comments
 (0)