From 4718586f543d784661dcd7d1311cc4a441317508 Mon Sep 17 00:00:00 2001 From: Oleg Yukhnevich Date: Fri, 7 Mar 2025 00:33:03 +0200 Subject: [PATCH] Add klib BCV --- ...cketbuild.multiplatform-library.gradle.kts | 9 +- .../api/ktor-client-rsocket.klib.api | 19 + .../api/ktor-server-rsocket.klib.api | 18 + .../api/rsocket-ktor-client.klib.api | 8 + .../api/rsocket-ktor-server.klib.api | 8 + rsocket-core/api/rsocket-core.klib.api | 841 ++++++++++++++++++ .../api/rsocket-internal-io.klib.api | 20 + .../api/rsocket-transport-ktor-tcp.klib.api | 48 + ...t-transport-ktor-websocket-client.klib.api | 26 + ...transport-ktor-websocket-internal.klib.api | 27 + ...t-transport-ktor-websocket-server.klib.api | 33 + .../api/rsocket-transport-local.klib.api | 44 + .../rsocket-transport-netty-internal.klib.api | 0 .../api/rsocket-transport-netty-quic.klib.api | 0 .../api/rsocket-transport-netty-tcp.klib.api | 0 .../api/rsocket-transport-nodejs-tcp.klib.api | 29 + 16 files changed, 1129 insertions(+), 1 deletion(-) create mode 100644 ktor-plugins/ktor-client-rsocket/api/ktor-client-rsocket.klib.api create mode 100644 ktor-plugins/ktor-server-rsocket/api/ktor-server-rsocket.klib.api create mode 100644 ktor-plugins/rsocket-ktor-client/api/rsocket-ktor-client.klib.api create mode 100644 ktor-plugins/rsocket-ktor-server/api/rsocket-ktor-server.klib.api create mode 100644 rsocket-core/api/rsocket-core.klib.api create mode 100644 rsocket-internal-io/api/rsocket-internal-io.klib.api create mode 100644 rsocket-transports/ktor-tcp/api/rsocket-transport-ktor-tcp.klib.api create mode 100644 rsocket-transports/ktor-websocket-client/api/rsocket-transport-ktor-websocket-client.klib.api create mode 100644 rsocket-transports/ktor-websocket-internal/api/rsocket-transport-ktor-websocket-internal.klib.api create mode 100644 rsocket-transports/ktor-websocket-server/api/rsocket-transport-ktor-websocket-server.klib.api create mode 100644 rsocket-transports/local/api/rsocket-transport-local.klib.api create mode 100644 rsocket-transports/netty-internal/api/rsocket-transport-netty-internal.klib.api create mode 100644 rsocket-transports/netty-quic/api/rsocket-transport-netty-quic.klib.api create mode 100644 rsocket-transports/netty-tcp/api/rsocket-transport-netty-tcp.klib.api create mode 100644 rsocket-transports/nodejs-tcp/api/rsocket-transport-nodejs-tcp.klib.api diff --git a/build-logic/src/main/kotlin/rsocketbuild.multiplatform-library.gradle.kts b/build-logic/src/main/kotlin/rsocketbuild.multiplatform-library.gradle.kts index c85fac57f..233594fd4 100644 --- a/build-logic/src/main/kotlin/rsocketbuild.multiplatform-library.gradle.kts +++ b/build-logic/src/main/kotlin/rsocketbuild.multiplatform-library.gradle.kts @@ -1,5 +1,5 @@ /* - * Copyright 2015-2024 the original author or authors. + * Copyright 2015-2025 the original author or authors. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -14,6 +14,8 @@ * limitations under the License. */ +import kotlinx.validation.* + plugins { id("rsocketbuild.multiplatform-base") id("rsocketbuild.publication") @@ -23,3 +25,8 @@ plugins { kotlin { explicitApi() } + +apiValidation { + @OptIn(ExperimentalBCVApi::class) + klib.enabled = true +} diff --git a/ktor-plugins/ktor-client-rsocket/api/ktor-client-rsocket.klib.api b/ktor-plugins/ktor-client-rsocket/api/ktor-client-rsocket.klib.api new file mode 100644 index 000000000..6c6b01aaa --- /dev/null +++ b/ktor-plugins/ktor-client-rsocket/api/ktor-client-rsocket.klib.api @@ -0,0 +1,19 @@ +// Klib ABI Dump +// Targets: [androidNativeArm32, androidNativeArm64, androidNativeX64, androidNativeX86, iosArm64, iosSimulatorArm64, iosX64, js, linuxArm64, linuxX64, macosArm64, macosX64, mingwX64, tvosArm64, tvosSimulatorArm64, tvosX64, wasmJs, watchosArm32, watchosArm64, watchosDeviceArm64, watchosSimulatorArm64, watchosX64] +// Rendering settings: +// - Signature version: 2 +// - Show manifest properties: true +// - Show declarations: true + +// Library unique name: +final class io.rsocket.kotlin.ktor.client/RSocketSupportConfig { // io.rsocket.kotlin.ktor.client/RSocketSupportConfig|null[0] + final fun connector(io.rsocket.kotlin.core/RSocketConnector) // io.rsocket.kotlin.ktor.client/RSocketSupportConfig.connector|connector(io.rsocket.kotlin.core.RSocketConnector){}[0] + final fun connector(kotlin/Function1) // io.rsocket.kotlin.ktor.client/RSocketSupportConfig.connector|connector(kotlin.Function1){}[0] +} + +final val io.rsocket.kotlin.ktor.client/RSocketSupport // io.rsocket.kotlin.ktor.client/RSocketSupport|{}RSocketSupport[0] + final fun (): io.ktor.client.plugins.api/ClientPlugin // io.rsocket.kotlin.ktor.client/RSocketSupport.|(){}[0] + +final suspend fun (io.ktor.client/HttpClient).io.rsocket.kotlin.ktor.client/rSocket(kotlin/Function1): io.rsocket.kotlin/RSocket // io.rsocket.kotlin.ktor.client/rSocket|rSocket@io.ktor.client.HttpClient(kotlin.Function1){}[0] +final suspend fun (io.ktor.client/HttpClient).io.rsocket.kotlin.ktor.client/rSocket(kotlin/String, kotlin/Boolean = ..., kotlin/Function1 = ...): io.rsocket.kotlin/RSocket // io.rsocket.kotlin.ktor.client/rSocket|rSocket@io.ktor.client.HttpClient(kotlin.String;kotlin.Boolean;kotlin.Function1){}[0] +final suspend fun (io.ktor.client/HttpClient).io.rsocket.kotlin.ktor.client/rSocket(kotlin/String? = ..., kotlin/Int? = ..., kotlin/String? = ..., kotlin/Boolean = ..., kotlin/Function1 = ...): io.rsocket.kotlin/RSocket // io.rsocket.kotlin.ktor.client/rSocket|rSocket@io.ktor.client.HttpClient(kotlin.String?;kotlin.Int?;kotlin.String?;kotlin.Boolean;kotlin.Function1){}[0] diff --git a/ktor-plugins/ktor-server-rsocket/api/ktor-server-rsocket.klib.api b/ktor-plugins/ktor-server-rsocket/api/ktor-server-rsocket.klib.api new file mode 100644 index 000000000..604084420 --- /dev/null +++ b/ktor-plugins/ktor-server-rsocket/api/ktor-server-rsocket.klib.api @@ -0,0 +1,18 @@ +// Klib ABI Dump +// Targets: [androidNativeArm32, androidNativeArm64, androidNativeX64, androidNativeX86, iosArm64, iosSimulatorArm64, iosX64, js, linuxArm64, linuxX64, macosArm64, macosX64, mingwX64, tvosArm64, tvosSimulatorArm64, tvosX64, wasmJs, watchosArm32, watchosArm64, watchosDeviceArm64, watchosSimulatorArm64, watchosX64] +// Rendering settings: +// - Signature version: 2 +// - Show manifest properties: true +// - Show declarations: true + +// Library unique name: +final class io.rsocket.kotlin.ktor.server/RSocketSupportConfig { // io.rsocket.kotlin.ktor.server/RSocketSupportConfig|null[0] + final fun server(io.rsocket.kotlin.core/RSocketServer) // io.rsocket.kotlin.ktor.server/RSocketSupportConfig.server|server(io.rsocket.kotlin.core.RSocketServer){}[0] + final fun server(kotlin/Function1) // io.rsocket.kotlin.ktor.server/RSocketSupportConfig.server|server(kotlin.Function1){}[0] +} + +final val io.rsocket.kotlin.ktor.server/RSocketSupport // io.rsocket.kotlin.ktor.server/RSocketSupport|{}RSocketSupport[0] + final fun (): io.ktor.server.application/ApplicationPlugin // io.rsocket.kotlin.ktor.server/RSocketSupport.|(){}[0] + +final fun (io.ktor.server.routing/Route).io.rsocket.kotlin.ktor.server/rSocket(kotlin/String, kotlin/String? = ..., io.rsocket.kotlin/ConnectionAcceptor) // io.rsocket.kotlin.ktor.server/rSocket|rSocket@io.ktor.server.routing.Route(kotlin.String;kotlin.String?;io.rsocket.kotlin.ConnectionAcceptor){}[0] +final fun (io.ktor.server.routing/Route).io.rsocket.kotlin.ktor.server/rSocket(kotlin/String? = ..., io.rsocket.kotlin/ConnectionAcceptor) // io.rsocket.kotlin.ktor.server/rSocket|rSocket@io.ktor.server.routing.Route(kotlin.String?;io.rsocket.kotlin.ConnectionAcceptor){}[0] diff --git a/ktor-plugins/rsocket-ktor-client/api/rsocket-ktor-client.klib.api b/ktor-plugins/rsocket-ktor-client/api/rsocket-ktor-client.klib.api new file mode 100644 index 000000000..9d7fcbca7 --- /dev/null +++ b/ktor-plugins/rsocket-ktor-client/api/rsocket-ktor-client.klib.api @@ -0,0 +1,8 @@ +// Klib ABI Dump +// Targets: [androidNativeArm32, androidNativeArm64, androidNativeX64, androidNativeX86, iosArm64, iosSimulatorArm64, iosX64, js, linuxArm64, linuxX64, macosArm64, macosX64, mingwX64, tvosArm64, tvosSimulatorArm64, tvosX64, wasmJs, watchosArm32, watchosArm64, watchosDeviceArm64, watchosSimulatorArm64, watchosX64] +// Rendering settings: +// - Signature version: 2 +// - Show manifest properties: true +// - Show declarations: true + +// Library unique name: diff --git a/ktor-plugins/rsocket-ktor-server/api/rsocket-ktor-server.klib.api b/ktor-plugins/rsocket-ktor-server/api/rsocket-ktor-server.klib.api new file mode 100644 index 000000000..bf0e1a15c --- /dev/null +++ b/ktor-plugins/rsocket-ktor-server/api/rsocket-ktor-server.klib.api @@ -0,0 +1,8 @@ +// Klib ABI Dump +// Targets: [androidNativeArm32, androidNativeArm64, androidNativeX64, androidNativeX86, iosArm64, iosSimulatorArm64, iosX64, js, linuxArm64, linuxX64, macosArm64, macosX64, mingwX64, tvosArm64, tvosSimulatorArm64, tvosX64, wasmJs, watchosArm32, watchosArm64, watchosDeviceArm64, watchosSimulatorArm64, watchosX64] +// Rendering settings: +// - Signature version: 2 +// - Show manifest properties: true +// - Show declarations: true + +// Library unique name: diff --git a/rsocket-core/api/rsocket-core.klib.api b/rsocket-core/api/rsocket-core.klib.api new file mode 100644 index 000000000..b9608feea --- /dev/null +++ b/rsocket-core/api/rsocket-core.klib.api @@ -0,0 +1,841 @@ +// Klib ABI Dump +// Targets: [androidNativeArm32, androidNativeArm64, androidNativeX64, androidNativeX86, iosArm64, iosSimulatorArm64, iosX64, js, linuxArm64, linuxX64, macosArm64, macosX64, mingwX64, tvosArm64, tvosSimulatorArm64, tvosX64, wasmJs, wasmWasi, watchosArm32, watchosArm64, watchosDeviceArm64, watchosSimulatorArm64, watchosX64] +// Rendering settings: +// - Signature version: 2 +// - Show manifest properties: true +// - Show declarations: true + +// Library unique name: +open annotation class io.rsocket.kotlin.transport/RSocketTransportApi : kotlin/Annotation { // io.rsocket.kotlin.transport/RSocketTransportApi|null[0] + constructor () // io.rsocket.kotlin.transport/RSocketTransportApi.|(){}[0] +} + +open annotation class io.rsocket.kotlin/ExperimentalMetadataApi : kotlin/Annotation { // io.rsocket.kotlin/ExperimentalMetadataApi|null[0] + constructor () // io.rsocket.kotlin/ExperimentalMetadataApi.|(){}[0] +} + +open annotation class io.rsocket.kotlin/ExperimentalStreamsApi : kotlin/Annotation { // io.rsocket.kotlin/ExperimentalStreamsApi|null[0] + constructor () // io.rsocket.kotlin/ExperimentalStreamsApi.|(){}[0] +} + +open annotation class io.rsocket.kotlin/RSocketLoggingApi : kotlin/Annotation { // io.rsocket.kotlin/RSocketLoggingApi|null[0] + constructor () // io.rsocket.kotlin/RSocketLoggingApi.|(){}[0] +} + +open annotation class io.rsocket.kotlin/TransportApi : kotlin/Annotation { // io.rsocket.kotlin/TransportApi|null[0] + constructor () // io.rsocket.kotlin/TransportApi.|(){}[0] +} + +final enum class io.rsocket.kotlin.core/WellKnownMimeType : io.rsocket.kotlin.core/MimeTypeWithId, io.rsocket.kotlin.core/MimeTypeWithName, kotlin/Enum { // io.rsocket.kotlin.core/WellKnownMimeType|null[0] + enum entry ApplicationAvro // io.rsocket.kotlin.core/WellKnownMimeType.ApplicationAvro|null[0] + enum entry ApplicationCapnProto // io.rsocket.kotlin.core/WellKnownMimeType.ApplicationCapnProto|null[0] + enum entry ApplicationCbor // io.rsocket.kotlin.core/WellKnownMimeType.ApplicationCbor|null[0] + enum entry ApplicationCloudeventsJson // io.rsocket.kotlin.core/WellKnownMimeType.ApplicationCloudeventsJson|null[0] + enum entry ApplicationFlatBuffers // io.rsocket.kotlin.core/WellKnownMimeType.ApplicationFlatBuffers|null[0] + enum entry ApplicationGraphql // io.rsocket.kotlin.core/WellKnownMimeType.ApplicationGraphql|null[0] + enum entry ApplicationGzip // io.rsocket.kotlin.core/WellKnownMimeType.ApplicationGzip|null[0] + enum entry ApplicationHessian // io.rsocket.kotlin.core/WellKnownMimeType.ApplicationHessian|null[0] + enum entry ApplicationJavaObject // io.rsocket.kotlin.core/WellKnownMimeType.ApplicationJavaObject|null[0] + enum entry ApplicationJavascript // io.rsocket.kotlin.core/WellKnownMimeType.ApplicationJavascript|null[0] + enum entry ApplicationJson // io.rsocket.kotlin.core/WellKnownMimeType.ApplicationJson|null[0] + enum entry ApplicationOctetStream // io.rsocket.kotlin.core/WellKnownMimeType.ApplicationOctetStream|null[0] + enum entry ApplicationPdf // io.rsocket.kotlin.core/WellKnownMimeType.ApplicationPdf|null[0] + enum entry ApplicationProtoBuf // io.rsocket.kotlin.core/WellKnownMimeType.ApplicationProtoBuf|null[0] + enum entry ApplicationThrift // io.rsocket.kotlin.core/WellKnownMimeType.ApplicationThrift|null[0] + enum entry ApplicationXml // io.rsocket.kotlin.core/WellKnownMimeType.ApplicationXml|null[0] + enum entry ApplicationZip // io.rsocket.kotlin.core/WellKnownMimeType.ApplicationZip|null[0] + enum entry AudioAac // io.rsocket.kotlin.core/WellKnownMimeType.AudioAac|null[0] + enum entry AudioMp3 // io.rsocket.kotlin.core/WellKnownMimeType.AudioMp3|null[0] + enum entry AudioMp4 // io.rsocket.kotlin.core/WellKnownMimeType.AudioMp4|null[0] + enum entry AudioMpeg // io.rsocket.kotlin.core/WellKnownMimeType.AudioMpeg|null[0] + enum entry AudioMpeg3 // io.rsocket.kotlin.core/WellKnownMimeType.AudioMpeg3|null[0] + enum entry AudioOgg // io.rsocket.kotlin.core/WellKnownMimeType.AudioOgg|null[0] + enum entry AudioOpus // io.rsocket.kotlin.core/WellKnownMimeType.AudioOpus|null[0] + enum entry AudioVorbis // io.rsocket.kotlin.core/WellKnownMimeType.AudioVorbis|null[0] + enum entry ImageBmp // io.rsocket.kotlin.core/WellKnownMimeType.ImageBmp|null[0] + enum entry ImageGif // io.rsocket.kotlin.core/WellKnownMimeType.ImageGif|null[0] + enum entry ImageHeic // io.rsocket.kotlin.core/WellKnownMimeType.ImageHeic|null[0] + enum entry ImageHeicSequence // io.rsocket.kotlin.core/WellKnownMimeType.ImageHeicSequence|null[0] + enum entry ImageHeif // io.rsocket.kotlin.core/WellKnownMimeType.ImageHeif|null[0] + enum entry ImageHeifSequence // io.rsocket.kotlin.core/WellKnownMimeType.ImageHeifSequence|null[0] + enum entry ImageJpeg // io.rsocket.kotlin.core/WellKnownMimeType.ImageJpeg|null[0] + enum entry ImagePng // io.rsocket.kotlin.core/WellKnownMimeType.ImagePng|null[0] + enum entry ImageTiff // io.rsocket.kotlin.core/WellKnownMimeType.ImageTiff|null[0] + enum entry MessageRSocketAcceptMimeTypes // io.rsocket.kotlin.core/WellKnownMimeType.MessageRSocketAcceptMimeTypes|null[0] + enum entry MessageRSocketAuthentication // io.rsocket.kotlin.core/WellKnownMimeType.MessageRSocketAuthentication|null[0] + enum entry MessageRSocketCompositeMetadata // io.rsocket.kotlin.core/WellKnownMimeType.MessageRSocketCompositeMetadata|null[0] + enum entry MessageRSocketMimeType // io.rsocket.kotlin.core/WellKnownMimeType.MessageRSocketMimeType|null[0] + enum entry MessageRSocketRouting // io.rsocket.kotlin.core/WellKnownMimeType.MessageRSocketRouting|null[0] + enum entry MessageRSocketTracingZipkin // io.rsocket.kotlin.core/WellKnownMimeType.MessageRSocketTracingZipkin|null[0] + enum entry MultipartMixed // io.rsocket.kotlin.core/WellKnownMimeType.MultipartMixed|null[0] + enum entry TextCss // io.rsocket.kotlin.core/WellKnownMimeType.TextCss|null[0] + enum entry TextCsv // io.rsocket.kotlin.core/WellKnownMimeType.TextCsv|null[0] + enum entry TextHtml // io.rsocket.kotlin.core/WellKnownMimeType.TextHtml|null[0] + enum entry TextPlain // io.rsocket.kotlin.core/WellKnownMimeType.TextPlain|null[0] + enum entry TextXml // io.rsocket.kotlin.core/WellKnownMimeType.TextXml|null[0] + enum entry VideoH264 // io.rsocket.kotlin.core/WellKnownMimeType.VideoH264|null[0] + enum entry VideoH265 // io.rsocket.kotlin.core/WellKnownMimeType.VideoH265|null[0] + enum entry VideoVp8 // io.rsocket.kotlin.core/WellKnownMimeType.VideoVp8|null[0] + + final val entries // io.rsocket.kotlin.core/WellKnownMimeType.entries|#static{}entries[0] + final fun (): kotlin.enums/EnumEntries // io.rsocket.kotlin.core/WellKnownMimeType.entries.|#static(){}[0] + final val identifier // io.rsocket.kotlin.core/WellKnownMimeType.identifier|{}identifier[0] + final fun (): kotlin/Byte // io.rsocket.kotlin.core/WellKnownMimeType.identifier.|(){}[0] + final val text // io.rsocket.kotlin.core/WellKnownMimeType.text|{}text[0] + final fun (): kotlin/String // io.rsocket.kotlin.core/WellKnownMimeType.text.|(){}[0] + + final fun toString(): kotlin/String // io.rsocket.kotlin.core/WellKnownMimeType.toString|toString(){}[0] + final fun valueOf(kotlin/String): io.rsocket.kotlin.core/WellKnownMimeType // io.rsocket.kotlin.core/WellKnownMimeType.valueOf|valueOf#static(kotlin.String){}[0] + final fun values(): kotlin/Array // io.rsocket.kotlin.core/WellKnownMimeType.values|values#static(){}[0] + + final object Companion { // io.rsocket.kotlin.core/WellKnownMimeType.Companion|null[0] + final fun invoke(kotlin/Byte): io.rsocket.kotlin.core/WellKnownMimeType? // io.rsocket.kotlin.core/WellKnownMimeType.Companion.invoke|invoke(kotlin.Byte){}[0] + final fun invoke(kotlin/String): io.rsocket.kotlin.core/WellKnownMimeType? // io.rsocket.kotlin.core/WellKnownMimeType.Companion.invoke|invoke(kotlin.String){}[0] + } +} + +final enum class io.rsocket.kotlin.logging/LoggingLevel : kotlin/Enum { // io.rsocket.kotlin.logging/LoggingLevel|null[0] + enum entry DEBUG // io.rsocket.kotlin.logging/LoggingLevel.DEBUG|null[0] + enum entry ERROR // io.rsocket.kotlin.logging/LoggingLevel.ERROR|null[0] + enum entry INFO // io.rsocket.kotlin.logging/LoggingLevel.INFO|null[0] + enum entry TRACE // io.rsocket.kotlin.logging/LoggingLevel.TRACE|null[0] + enum entry WARN // io.rsocket.kotlin.logging/LoggingLevel.WARN|null[0] + + final val entries // io.rsocket.kotlin.logging/LoggingLevel.entries|#static{}entries[0] + final fun (): kotlin.enums/EnumEntries // io.rsocket.kotlin.logging/LoggingLevel.entries.|#static(){}[0] + + final fun valueOf(kotlin/String): io.rsocket.kotlin.logging/LoggingLevel // io.rsocket.kotlin.logging/LoggingLevel.valueOf|valueOf#static(kotlin.String){}[0] + final fun values(): kotlin/Array // io.rsocket.kotlin.logging/LoggingLevel.values|values#static(){}[0] +} + +final enum class io.rsocket.kotlin.metadata.security/WellKnowAuthType : io.rsocket.kotlin.metadata.security/AuthTypeWithId, io.rsocket.kotlin.metadata.security/AuthTypeWithName, kotlin/Enum { // io.rsocket.kotlin.metadata.security/WellKnowAuthType|null[0] + enum entry Bearer // io.rsocket.kotlin.metadata.security/WellKnowAuthType.Bearer|null[0] + enum entry Simple // io.rsocket.kotlin.metadata.security/WellKnowAuthType.Simple|null[0] + + final val entries // io.rsocket.kotlin.metadata.security/WellKnowAuthType.entries|#static{}entries[0] + final fun (): kotlin.enums/EnumEntries // io.rsocket.kotlin.metadata.security/WellKnowAuthType.entries.|#static(){}[0] + final val identifier // io.rsocket.kotlin.metadata.security/WellKnowAuthType.identifier|{}identifier[0] + final fun (): kotlin/Byte // io.rsocket.kotlin.metadata.security/WellKnowAuthType.identifier.|(){}[0] + final val text // io.rsocket.kotlin.metadata.security/WellKnowAuthType.text|{}text[0] + final fun (): kotlin/String // io.rsocket.kotlin.metadata.security/WellKnowAuthType.text.|(){}[0] + + final fun toString(): kotlin/String // io.rsocket.kotlin.metadata.security/WellKnowAuthType.toString|toString(){}[0] + final fun valueOf(kotlin/String): io.rsocket.kotlin.metadata.security/WellKnowAuthType // io.rsocket.kotlin.metadata.security/WellKnowAuthType.valueOf|valueOf#static(kotlin.String){}[0] + final fun values(): kotlin/Array // io.rsocket.kotlin.metadata.security/WellKnowAuthType.values|values#static(){}[0] + + final object Companion { // io.rsocket.kotlin.metadata.security/WellKnowAuthType.Companion|null[0] + final fun invoke(kotlin/Byte): io.rsocket.kotlin.metadata.security/WellKnowAuthType? // io.rsocket.kotlin.metadata.security/WellKnowAuthType.Companion.invoke|invoke(kotlin.Byte){}[0] + final fun invoke(kotlin/String): io.rsocket.kotlin.metadata.security/WellKnowAuthType? // io.rsocket.kotlin.metadata.security/WellKnowAuthType.Companion.invoke|invoke(kotlin.String){}[0] + } +} + +abstract fun interface <#A: kotlin/Any?> io.rsocket.kotlin.core/Interceptor { // io.rsocket.kotlin.core/Interceptor|null[0] + abstract fun intercept(#A): #A // io.rsocket.kotlin.core/Interceptor.intercept|intercept(1:0){}[0] +} + +abstract fun interface <#A: kotlin/Any?> io.rsocket.kotlin.transport/ServerTransport { // io.rsocket.kotlin.transport/ServerTransport|null[0] + abstract fun (kotlinx.coroutines/CoroutineScope).start(kotlin.coroutines/SuspendFunction2): #A // io.rsocket.kotlin.transport/ServerTransport.start|start@kotlinx.coroutines.CoroutineScope(kotlin.coroutines.SuspendFunction2){}[0] +} + +abstract fun interface io.rsocket.kotlin.logging/LoggerFactory { // io.rsocket.kotlin.logging/LoggerFactory|null[0] + abstract fun logger(kotlin/String): io.rsocket.kotlin.logging/Logger // io.rsocket.kotlin.logging/LoggerFactory.logger|logger(kotlin.String){}[0] +} + +abstract fun interface io.rsocket.kotlin.transport/ClientTransport : kotlinx.coroutines/CoroutineScope { // io.rsocket.kotlin.transport/ClientTransport|null[0] + open val coroutineContext // io.rsocket.kotlin.transport/ClientTransport.coroutineContext|{}coroutineContext[0] + open fun (): kotlin.coroutines/CoroutineContext // io.rsocket.kotlin.transport/ClientTransport.coroutineContext.|(){}[0] + + abstract suspend fun connect(): io.rsocket.kotlin/Connection // io.rsocket.kotlin.transport/ClientTransport.connect|connect(){}[0] +} + +abstract fun interface io.rsocket.kotlin/ConnectionAcceptor { // io.rsocket.kotlin/ConnectionAcceptor|null[0] + abstract suspend fun (io.rsocket.kotlin/ConnectionAcceptorContext).accept(): io.rsocket.kotlin/RSocket // io.rsocket.kotlin/ConnectionAcceptor.accept|accept@io.rsocket.kotlin.ConnectionAcceptorContext(){}[0] +} + +abstract interface <#A: io.rsocket.kotlin.metadata/Metadata> io.rsocket.kotlin.metadata/MetadataReader { // io.rsocket.kotlin.metadata/MetadataReader|null[0] + abstract val mimeType // io.rsocket.kotlin.metadata/MetadataReader.mimeType|{}mimeType[0] + abstract fun (): io.rsocket.kotlin.core/MimeType // io.rsocket.kotlin.metadata/MetadataReader.mimeType.|(){}[0] + + abstract fun (kotlinx.io/Source).read(): #A // io.rsocket.kotlin.metadata/MetadataReader.read|read@kotlinx.io.Source(){}[0] +} + +abstract interface <#A: io.rsocket.kotlin.transport/RSocketServerInstance> io.rsocket.kotlin.transport/RSocketServerTarget : kotlinx.coroutines/CoroutineScope { // io.rsocket.kotlin.transport/RSocketServerTarget|null[0] + abstract suspend fun startServer(kotlin/Function1): #A // io.rsocket.kotlin.transport/RSocketServerTarget.startServer|startServer(kotlin.Function1){}[0] +} + +abstract interface <#A: io.rsocket.kotlin.transport/RSocketTransport> io.rsocket.kotlin.transport/RSocketTransportBuilder { // io.rsocket.kotlin.transport/RSocketTransportBuilder|null[0] + abstract fun buildTransport(kotlin.coroutines/CoroutineContext): #A // io.rsocket.kotlin.transport/RSocketTransportBuilder.buildTransport|buildTransport(kotlin.coroutines.CoroutineContext){}[0] +} + +abstract interface io.rsocket.kotlin.logging/Logger { // io.rsocket.kotlin.logging/Logger|null[0] + abstract val tag // io.rsocket.kotlin.logging/Logger.tag|{}tag[0] + abstract fun (): kotlin/String // io.rsocket.kotlin.logging/Logger.tag.|(){}[0] + + abstract fun isLoggable(io.rsocket.kotlin.logging/LoggingLevel): kotlin/Boolean // io.rsocket.kotlin.logging/Logger.isLoggable|isLoggable(io.rsocket.kotlin.logging.LoggingLevel){}[0] + abstract fun rawLog(io.rsocket.kotlin.logging/LoggingLevel, kotlin/Throwable?, kotlin/Any?) // io.rsocket.kotlin.logging/Logger.rawLog|rawLog(io.rsocket.kotlin.logging.LoggingLevel;kotlin.Throwable?;kotlin.Any?){}[0] +} + +abstract interface io.rsocket.kotlin.metadata/Metadata : kotlin/AutoCloseable { // io.rsocket.kotlin.metadata/Metadata|null[0] + abstract val mimeType // io.rsocket.kotlin.metadata/Metadata.mimeType|{}mimeType[0] + abstract fun (): io.rsocket.kotlin.core/MimeType // io.rsocket.kotlin.metadata/Metadata.mimeType.|(){}[0] + + abstract fun (kotlinx.io/Sink).writeSelf() // io.rsocket.kotlin.metadata/Metadata.writeSelf|writeSelf@kotlinx.io.Sink(){}[0] +} + +abstract interface io.rsocket.kotlin.transport/RSocketClientTarget : kotlinx.coroutines/CoroutineScope { // io.rsocket.kotlin.transport/RSocketClientTarget|null[0] + abstract suspend fun connectClient(): io.rsocket.kotlin.transport/RSocketConnection // io.rsocket.kotlin.transport/RSocketClientTarget.connectClient|connectClient(){}[0] +} + +abstract interface io.rsocket.kotlin.transport/RSocketMultiplexedConnection : io.rsocket.kotlin.transport/RSocketConnection { // io.rsocket.kotlin.transport/RSocketMultiplexedConnection|null[0] + abstract suspend fun acceptStream(): io.rsocket.kotlin.transport/RSocketMultiplexedConnection.Stream? // io.rsocket.kotlin.transport/RSocketMultiplexedConnection.acceptStream|acceptStream(){}[0] + abstract suspend fun createStream(): io.rsocket.kotlin.transport/RSocketMultiplexedConnection.Stream // io.rsocket.kotlin.transport/RSocketMultiplexedConnection.createStream|createStream(){}[0] + + abstract interface Stream : kotlinx.coroutines/CoroutineScope { // io.rsocket.kotlin.transport/RSocketMultiplexedConnection.Stream|null[0] + abstract fun setSendPriority(kotlin/Int) // io.rsocket.kotlin.transport/RSocketMultiplexedConnection.Stream.setSendPriority|setSendPriority(kotlin.Int){}[0] + abstract suspend fun receiveFrame(): kotlinx.io/Buffer? // io.rsocket.kotlin.transport/RSocketMultiplexedConnection.Stream.receiveFrame|receiveFrame(){}[0] + abstract suspend fun sendFrame(kotlinx.io/Buffer) // io.rsocket.kotlin.transport/RSocketMultiplexedConnection.Stream.sendFrame|sendFrame(kotlinx.io.Buffer){}[0] + } +} + +abstract interface io.rsocket.kotlin.transport/RSocketSequentialConnection : io.rsocket.kotlin.transport/RSocketConnection { // io.rsocket.kotlin.transport/RSocketSequentialConnection|null[0] + abstract suspend fun receiveFrame(): kotlinx.io/Buffer? // io.rsocket.kotlin.transport/RSocketSequentialConnection.receiveFrame|receiveFrame(){}[0] + abstract suspend fun sendFrame(kotlin/Int, kotlinx.io/Buffer) // io.rsocket.kotlin.transport/RSocketSequentialConnection.sendFrame|sendFrame(kotlin.Int;kotlinx.io.Buffer){}[0] +} + +abstract interface io.rsocket.kotlin.transport/RSocketServerInstance : kotlinx.coroutines/CoroutineScope // io.rsocket.kotlin.transport/RSocketServerInstance|null[0] + +abstract interface io.rsocket.kotlin.transport/RSocketTransport : kotlinx.coroutines/CoroutineScope // io.rsocket.kotlin.transport/RSocketTransport|null[0] + +abstract interface io.rsocket.kotlin/Connection : kotlinx.coroutines/CoroutineScope { // io.rsocket.kotlin/Connection|null[0] + abstract suspend fun receive(): kotlinx.io/Buffer // io.rsocket.kotlin/Connection.receive|receive(){}[0] + abstract suspend fun send(kotlinx.io/Buffer) // io.rsocket.kotlin/Connection.send|send(kotlinx.io.Buffer){}[0] +} + +abstract interface io.rsocket.kotlin/RSocket : kotlinx.coroutines/CoroutineScope { // io.rsocket.kotlin/RSocket|null[0] + open fun requestChannel(io.rsocket.kotlin.payload/Payload, kotlinx.coroutines.flow/Flow): kotlinx.coroutines.flow/Flow // io.rsocket.kotlin/RSocket.requestChannel|requestChannel(io.rsocket.kotlin.payload.Payload;kotlinx.coroutines.flow.Flow){}[0] + open fun requestStream(io.rsocket.kotlin.payload/Payload): kotlinx.coroutines.flow/Flow // io.rsocket.kotlin/RSocket.requestStream|requestStream(io.rsocket.kotlin.payload.Payload){}[0] + open suspend fun fireAndForget(io.rsocket.kotlin.payload/Payload) // io.rsocket.kotlin/RSocket.fireAndForget|fireAndForget(io.rsocket.kotlin.payload.Payload){}[0] + open suspend fun metadataPush(kotlinx.io/Buffer) // io.rsocket.kotlin/RSocket.metadataPush|metadataPush(kotlinx.io.Buffer){}[0] + open suspend fun requestResponse(io.rsocket.kotlin.payload/Payload): io.rsocket.kotlin.payload/Payload // io.rsocket.kotlin/RSocket.requestResponse|requestResponse(io.rsocket.kotlin.payload.Payload){}[0] +} + +abstract interface io.rsocket.kotlin/RequestStrategy : kotlin.coroutines/CoroutineContext.Element { // io.rsocket.kotlin/RequestStrategy|null[0] + open val key // io.rsocket.kotlin/RequestStrategy.key|{}key[0] + open fun (): kotlin.coroutines/CoroutineContext.Key<*> // io.rsocket.kotlin/RequestStrategy.key.|(){}[0] + + abstract fun provide(): io.rsocket.kotlin/RequestStrategy.Element // io.rsocket.kotlin/RequestStrategy.provide|provide(){}[0] + + abstract interface Element { // io.rsocket.kotlin/RequestStrategy.Element|null[0] + abstract suspend fun firstRequest(): kotlin/Int // io.rsocket.kotlin/RequestStrategy.Element.firstRequest|firstRequest(){}[0] + abstract suspend fun nextRequest(): kotlin/Int // io.rsocket.kotlin/RequestStrategy.Element.nextRequest|nextRequest(){}[0] + } + + final object Key : kotlin.coroutines/CoroutineContext.Key // io.rsocket.kotlin/RequestStrategy.Key|null[0] +} + +sealed interface <#A: io.rsocket.kotlin.metadata.security/AuthMetadata> io.rsocket.kotlin.metadata.security/AuthMetadataReader : io.rsocket.kotlin.metadata/MetadataReader<#A> { // io.rsocket.kotlin.metadata.security/AuthMetadataReader|null[0] + open val mimeType // io.rsocket.kotlin.metadata.security/AuthMetadataReader.mimeType|{}mimeType[0] + open fun (): io.rsocket.kotlin.core/MimeType // io.rsocket.kotlin.metadata.security/AuthMetadataReader.mimeType.|(){}[0] + + abstract fun (kotlinx.io/Source).readContent(io.rsocket.kotlin.metadata.security/AuthType): #A // io.rsocket.kotlin.metadata.security/AuthMetadataReader.readContent|readContent@kotlinx.io.Source(io.rsocket.kotlin.metadata.security.AuthType){}[0] + open fun (kotlinx.io/Source).read(): #A // io.rsocket.kotlin.metadata.security/AuthMetadataReader.read|read@kotlinx.io.Source(){}[0] +} + +sealed interface io.rsocket.kotlin.core/MimeType // io.rsocket.kotlin.core/MimeType|null[0] + +sealed interface io.rsocket.kotlin.core/MimeTypeWithId : io.rsocket.kotlin.core/MimeType { // io.rsocket.kotlin.core/MimeTypeWithId|null[0] + abstract val identifier // io.rsocket.kotlin.core/MimeTypeWithId.identifier|{}identifier[0] + abstract fun (): kotlin/Byte // io.rsocket.kotlin.core/MimeTypeWithId.identifier.|(){}[0] +} + +sealed interface io.rsocket.kotlin.core/MimeTypeWithName : io.rsocket.kotlin.core/MimeType { // io.rsocket.kotlin.core/MimeTypeWithName|null[0] + abstract val text // io.rsocket.kotlin.core/MimeTypeWithName.text|{}text[0] + abstract fun (): kotlin/String // io.rsocket.kotlin.core/MimeTypeWithName.text.|(){}[0] +} + +sealed interface io.rsocket.kotlin.metadata.security/AuthMetadata : io.rsocket.kotlin.metadata/Metadata { // io.rsocket.kotlin.metadata.security/AuthMetadata|null[0] + abstract val type // io.rsocket.kotlin.metadata.security/AuthMetadata.type|{}type[0] + abstract fun (): io.rsocket.kotlin.metadata.security/AuthType // io.rsocket.kotlin.metadata.security/AuthMetadata.type.|(){}[0] + open val mimeType // io.rsocket.kotlin.metadata.security/AuthMetadata.mimeType|{}mimeType[0] + open fun (): io.rsocket.kotlin.core/MimeType // io.rsocket.kotlin.metadata.security/AuthMetadata.mimeType.|(){}[0] + + abstract fun (kotlinx.io/Sink).writeContent() // io.rsocket.kotlin.metadata.security/AuthMetadata.writeContent|writeContent@kotlinx.io.Sink(){}[0] + open fun (kotlinx.io/Sink).writeSelf() // io.rsocket.kotlin.metadata.security/AuthMetadata.writeSelf|writeSelf@kotlinx.io.Sink(){}[0] +} + +sealed interface io.rsocket.kotlin.metadata.security/AuthType // io.rsocket.kotlin.metadata.security/AuthType|null[0] + +sealed interface io.rsocket.kotlin.metadata.security/AuthTypeWithId : io.rsocket.kotlin.metadata.security/AuthType { // io.rsocket.kotlin.metadata.security/AuthTypeWithId|null[0] + abstract val identifier // io.rsocket.kotlin.metadata.security/AuthTypeWithId.identifier|{}identifier[0] + abstract fun (): kotlin/Byte // io.rsocket.kotlin.metadata.security/AuthTypeWithId.identifier.|(){}[0] +} + +sealed interface io.rsocket.kotlin.metadata.security/AuthTypeWithName : io.rsocket.kotlin.metadata.security/AuthType { // io.rsocket.kotlin.metadata.security/AuthTypeWithName|null[0] + abstract val text // io.rsocket.kotlin.metadata.security/AuthTypeWithName.text|{}text[0] + abstract fun (): kotlin/String // io.rsocket.kotlin.metadata.security/AuthTypeWithName.text.|(){}[0] +} + +sealed interface io.rsocket.kotlin.metadata/CompositeMetadata : io.rsocket.kotlin.metadata/Metadata { // io.rsocket.kotlin.metadata/CompositeMetadata|null[0] + abstract val entries // io.rsocket.kotlin.metadata/CompositeMetadata.entries|{}entries[0] + abstract fun (): kotlin.collections/List // io.rsocket.kotlin.metadata/CompositeMetadata.entries.|(){}[0] + open val mimeType // io.rsocket.kotlin.metadata/CompositeMetadata.mimeType|{}mimeType[0] + open fun (): io.rsocket.kotlin.core/MimeType // io.rsocket.kotlin.metadata/CompositeMetadata.mimeType.|(){}[0] + + open fun (kotlinx.io/Sink).writeSelf() // io.rsocket.kotlin.metadata/CompositeMetadata.writeSelf|writeSelf@kotlinx.io.Sink(){}[0] + open fun close() // io.rsocket.kotlin.metadata/CompositeMetadata.close|close(){}[0] + + final class Entry { // io.rsocket.kotlin.metadata/CompositeMetadata.Entry|null[0] + constructor (io.rsocket.kotlin.core/MimeType, kotlinx.io/Buffer) // io.rsocket.kotlin.metadata/CompositeMetadata.Entry.|(io.rsocket.kotlin.core.MimeType;kotlinx.io.Buffer){}[0] + constructor (io.rsocket.kotlin.metadata/Metadata) // io.rsocket.kotlin.metadata/CompositeMetadata.Entry.|(io.rsocket.kotlin.metadata.Metadata){}[0] + + final val content // io.rsocket.kotlin.metadata/CompositeMetadata.Entry.content|{}content[0] + final fun (): kotlinx.io/Buffer // io.rsocket.kotlin.metadata/CompositeMetadata.Entry.content.|(){}[0] + final val mimeType // io.rsocket.kotlin.metadata/CompositeMetadata.Entry.mimeType|{}mimeType[0] + final fun (): io.rsocket.kotlin.core/MimeType // io.rsocket.kotlin.metadata/CompositeMetadata.Entry.mimeType.|(){}[0] + } + + final object Reader : io.rsocket.kotlin.metadata/MetadataReader { // io.rsocket.kotlin.metadata/CompositeMetadata.Reader|null[0] + final val mimeType // io.rsocket.kotlin.metadata/CompositeMetadata.Reader.mimeType|{}mimeType[0] + final fun (): io.rsocket.kotlin.core/MimeType // io.rsocket.kotlin.metadata/CompositeMetadata.Reader.mimeType.|(){}[0] + + final fun (kotlinx.io/Source).read(): io.rsocket.kotlin.metadata/CompositeMetadata // io.rsocket.kotlin.metadata/CompositeMetadata.Reader.read|read@kotlinx.io.Source(){}[0] + } +} + +sealed interface io.rsocket.kotlin.metadata/CompositeMetadataBuilder : kotlin/AutoCloseable { // io.rsocket.kotlin.metadata/CompositeMetadataBuilder|null[0] + abstract fun add(io.rsocket.kotlin.core/MimeType, kotlinx.io/Buffer) // io.rsocket.kotlin.metadata/CompositeMetadataBuilder.add|add(io.rsocket.kotlin.core.MimeType;kotlinx.io.Buffer){}[0] + abstract fun add(io.rsocket.kotlin.metadata/Metadata) // io.rsocket.kotlin.metadata/CompositeMetadataBuilder.add|add(io.rsocket.kotlin.metadata.Metadata){}[0] +} + +sealed interface io.rsocket.kotlin.payload/Payload : kotlin/AutoCloseable { // io.rsocket.kotlin.payload/Payload|null[0] + abstract val data // io.rsocket.kotlin.payload/Payload.data|{}data[0] + abstract fun (): kotlinx.io/Buffer // io.rsocket.kotlin.payload/Payload.data.|(){}[0] + abstract val metadata // io.rsocket.kotlin.payload/Payload.metadata|{}metadata[0] + abstract fun (): kotlinx.io/Buffer? // io.rsocket.kotlin.payload/Payload.metadata.|(){}[0] + + open fun close() // io.rsocket.kotlin.payload/Payload.close|close(){}[0] + open fun copy(): io.rsocket.kotlin.payload/Payload // io.rsocket.kotlin.payload/Payload.copy|copy(){}[0] + + final object Companion { // io.rsocket.kotlin.payload/Payload.Companion|null[0] + final val Empty // io.rsocket.kotlin.payload/Payload.Companion.Empty|{}Empty[0] + final fun (): io.rsocket.kotlin.payload/Payload // io.rsocket.kotlin.payload/Payload.Companion.Empty.|(){}[0] + } +} + +sealed interface io.rsocket.kotlin.payload/PayloadBuilder : kotlin/AutoCloseable { // io.rsocket.kotlin.payload/PayloadBuilder|null[0] + abstract fun data(kotlinx.io/Buffer) // io.rsocket.kotlin.payload/PayloadBuilder.data|data(kotlinx.io.Buffer){}[0] + abstract fun metadata(kotlinx.io/Buffer) // io.rsocket.kotlin.payload/PayloadBuilder.metadata|metadata(kotlinx.io.Buffer){}[0] +} + +sealed interface io.rsocket.kotlin.transport/RSocketConnection : kotlinx.coroutines/CoroutineScope // io.rsocket.kotlin.transport/RSocketConnection|null[0] + +abstract class <#A: io.rsocket.kotlin.transport/RSocketTransport, #B: io.rsocket.kotlin.transport/RSocketTransportBuilder<#A>> io.rsocket.kotlin.transport/RSocketTransportFactory { // io.rsocket.kotlin.transport/RSocketTransportFactory|null[0] + constructor (kotlin/Function0<#B>) // io.rsocket.kotlin.transport/RSocketTransportFactory.|(kotlin.Function0<1:1>){}[0] + + final val createBuilder // io.rsocket.kotlin.transport/RSocketTransportFactory.createBuilder|{}createBuilder[0] + final fun (): kotlin/Function0<#B> // io.rsocket.kotlin.transport/RSocketTransportFactory.createBuilder.|(){}[0] + + final inline fun invoke(kotlin.coroutines/CoroutineContext, kotlin/Function1<#B, kotlin/Unit> = ...): #A // io.rsocket.kotlin.transport/RSocketTransportFactory.invoke|invoke(kotlin.coroutines.CoroutineContext;kotlin.Function1<1:1,kotlin.Unit>){}[0] +} + +final class io.rsocket.kotlin.core/CustomMimeType : io.rsocket.kotlin.core/MimeTypeWithName { // io.rsocket.kotlin.core/CustomMimeType|null[0] + constructor (kotlin/String) // io.rsocket.kotlin.core/CustomMimeType.|(kotlin.String){}[0] + + final val text // io.rsocket.kotlin.core/CustomMimeType.text|{}text[0] + final fun (): kotlin/String // io.rsocket.kotlin.core/CustomMimeType.text.|(){}[0] + + final fun component1(): kotlin/String // io.rsocket.kotlin.core/CustomMimeType.component1|component1(){}[0] + final fun copy(kotlin/String = ...): io.rsocket.kotlin.core/CustomMimeType // io.rsocket.kotlin.core/CustomMimeType.copy|copy(kotlin.String){}[0] + final fun equals(kotlin/Any?): kotlin/Boolean // io.rsocket.kotlin.core/CustomMimeType.equals|equals(kotlin.Any?){}[0] + final fun hashCode(): kotlin/Int // io.rsocket.kotlin.core/CustomMimeType.hashCode|hashCode(){}[0] + final fun toString(): kotlin/String // io.rsocket.kotlin.core/CustomMimeType.toString|toString(){}[0] +} + +final class io.rsocket.kotlin.core/InterceptorsBuilder { // io.rsocket.kotlin.core/InterceptorsBuilder|null[0] + final fun forAcceptor(io.rsocket.kotlin.core/Interceptor) // io.rsocket.kotlin.core/InterceptorsBuilder.forAcceptor|forAcceptor(io.rsocket.kotlin.core.Interceptor){}[0] + final fun forConnection(io.rsocket.kotlin.core/Interceptor) // io.rsocket.kotlin.core/InterceptorsBuilder.forConnection|forConnection(io.rsocket.kotlin.core.Interceptor){}[0] + final fun forRequester(io.rsocket.kotlin.core/Interceptor) // io.rsocket.kotlin.core/InterceptorsBuilder.forRequester|forRequester(io.rsocket.kotlin.core.Interceptor){}[0] + final fun forResponder(io.rsocket.kotlin.core/Interceptor) // io.rsocket.kotlin.core/InterceptorsBuilder.forResponder|forResponder(io.rsocket.kotlin.core.Interceptor){}[0] +} + +final class io.rsocket.kotlin.core/RSocketConnector { // io.rsocket.kotlin.core/RSocketConnector|null[0] + final suspend fun connect(io.rsocket.kotlin.transport/ClientTransport): io.rsocket.kotlin/RSocket // io.rsocket.kotlin.core/RSocketConnector.connect|connect(io.rsocket.kotlin.transport.ClientTransport){}[0] + final suspend fun connect(io.rsocket.kotlin.transport/RSocketClientTarget): io.rsocket.kotlin/RSocket // io.rsocket.kotlin.core/RSocketConnector.connect|connect(io.rsocket.kotlin.transport.RSocketClientTarget){}[0] +} + +final class io.rsocket.kotlin.core/RSocketConnectorBuilder { // io.rsocket.kotlin.core/RSocketConnectorBuilder|null[0] + final var loggerFactory // io.rsocket.kotlin.core/RSocketConnectorBuilder.loggerFactory|{}loggerFactory[0] + final fun (): io.rsocket.kotlin.logging/LoggerFactory // io.rsocket.kotlin.core/RSocketConnectorBuilder.loggerFactory.|(){}[0] + final fun (io.rsocket.kotlin.logging/LoggerFactory) // io.rsocket.kotlin.core/RSocketConnectorBuilder.loggerFactory.|(io.rsocket.kotlin.logging.LoggerFactory){}[0] + final var maxFragmentSize // io.rsocket.kotlin.core/RSocketConnectorBuilder.maxFragmentSize|{}maxFragmentSize[0] + final fun (): kotlin/Int // io.rsocket.kotlin.core/RSocketConnectorBuilder.maxFragmentSize.|(){}[0] + final fun (kotlin/Int) // io.rsocket.kotlin.core/RSocketConnectorBuilder.maxFragmentSize.|(kotlin.Int){}[0] + + final fun acceptor(io.rsocket.kotlin/ConnectionAcceptor?) // io.rsocket.kotlin.core/RSocketConnectorBuilder.acceptor|acceptor(io.rsocket.kotlin.ConnectionAcceptor?){}[0] + final fun connectionConfig(kotlin/Function1) // io.rsocket.kotlin.core/RSocketConnectorBuilder.connectionConfig|connectionConfig(kotlin.Function1){}[0] + final fun interceptors(kotlin/Function1) // io.rsocket.kotlin.core/RSocketConnectorBuilder.interceptors|interceptors(kotlin.Function1){}[0] + final fun reconnectable(kotlin.coroutines/SuspendFunction2) // io.rsocket.kotlin.core/RSocketConnectorBuilder.reconnectable|reconnectable(kotlin.coroutines.SuspendFunction2){}[0] + final fun reconnectable(kotlin/Long, kotlin.coroutines/SuspendFunction1 = ...) // io.rsocket.kotlin.core/RSocketConnectorBuilder.reconnectable|reconnectable(kotlin.Long;kotlin.coroutines.SuspendFunction1){}[0] + + final class ConnectionConfigBuilder { // io.rsocket.kotlin.core/RSocketConnectorBuilder.ConnectionConfigBuilder|null[0] + final var keepAlive // io.rsocket.kotlin.core/RSocketConnectorBuilder.ConnectionConfigBuilder.keepAlive|{}keepAlive[0] + final fun (): io.rsocket.kotlin.keepalive/KeepAlive // io.rsocket.kotlin.core/RSocketConnectorBuilder.ConnectionConfigBuilder.keepAlive.|(){}[0] + final fun (io.rsocket.kotlin.keepalive/KeepAlive) // io.rsocket.kotlin.core/RSocketConnectorBuilder.ConnectionConfigBuilder.keepAlive.|(io.rsocket.kotlin.keepalive.KeepAlive){}[0] + final var payloadMimeType // io.rsocket.kotlin.core/RSocketConnectorBuilder.ConnectionConfigBuilder.payloadMimeType|{}payloadMimeType[0] + final fun (): io.rsocket.kotlin.payload/PayloadMimeType // io.rsocket.kotlin.core/RSocketConnectorBuilder.ConnectionConfigBuilder.payloadMimeType.|(){}[0] + final fun (io.rsocket.kotlin.payload/PayloadMimeType) // io.rsocket.kotlin.core/RSocketConnectorBuilder.ConnectionConfigBuilder.payloadMimeType.|(io.rsocket.kotlin.payload.PayloadMimeType){}[0] + + final fun setupPayload(io.rsocket.kotlin.payload/Payload) // io.rsocket.kotlin.core/RSocketConnectorBuilder.ConnectionConfigBuilder.setupPayload|setupPayload(io.rsocket.kotlin.payload.Payload){}[0] + final fun setupPayload(kotlin/Function0?) // io.rsocket.kotlin.core/RSocketConnectorBuilder.ConnectionConfigBuilder.setupPayload|setupPayload(kotlin.Function0?){}[0] + } +} + +final class io.rsocket.kotlin.core/RSocketServer { // io.rsocket.kotlin.core/RSocketServer|null[0] + final fun <#A1: kotlin/Any?> bind(io.rsocket.kotlin.transport/ServerTransport<#A1>, io.rsocket.kotlin/ConnectionAcceptor): #A1 // io.rsocket.kotlin.core/RSocketServer.bind|bind(io.rsocket.kotlin.transport.ServerTransport<0:0>;io.rsocket.kotlin.ConnectionAcceptor){0§}[0] + final fun <#A1: kotlin/Any?> bindIn(kotlinx.coroutines/CoroutineScope, io.rsocket.kotlin.transport/ServerTransport<#A1>, io.rsocket.kotlin/ConnectionAcceptor): #A1 // io.rsocket.kotlin.core/RSocketServer.bindIn|bindIn(kotlinx.coroutines.CoroutineScope;io.rsocket.kotlin.transport.ServerTransport<0:0>;io.rsocket.kotlin.ConnectionAcceptor){0§}[0] + final fun acceptConnection(io.rsocket.kotlin/ConnectionAcceptor, io.rsocket.kotlin.transport/RSocketConnection) // io.rsocket.kotlin.core/RSocketServer.acceptConnection|acceptConnection(io.rsocket.kotlin.ConnectionAcceptor;io.rsocket.kotlin.transport.RSocketConnection){}[0] + final suspend fun <#A1: io.rsocket.kotlin.transport/RSocketServerInstance> startServer(io.rsocket.kotlin.transport/RSocketServerTarget<#A1>, io.rsocket.kotlin/ConnectionAcceptor): #A1 // io.rsocket.kotlin.core/RSocketServer.startServer|startServer(io.rsocket.kotlin.transport.RSocketServerTarget<0:0>;io.rsocket.kotlin.ConnectionAcceptor){0§}[0] +} + +final class io.rsocket.kotlin.core/RSocketServerBuilder { // io.rsocket.kotlin.core/RSocketServerBuilder|null[0] + final var loggerFactory // io.rsocket.kotlin.core/RSocketServerBuilder.loggerFactory|{}loggerFactory[0] + final fun (): io.rsocket.kotlin.logging/LoggerFactory // io.rsocket.kotlin.core/RSocketServerBuilder.loggerFactory.|(){}[0] + final fun (io.rsocket.kotlin.logging/LoggerFactory) // io.rsocket.kotlin.core/RSocketServerBuilder.loggerFactory.|(io.rsocket.kotlin.logging.LoggerFactory){}[0] + final var maxFragmentSize // io.rsocket.kotlin.core/RSocketServerBuilder.maxFragmentSize|{}maxFragmentSize[0] + final fun (): kotlin/Int // io.rsocket.kotlin.core/RSocketServerBuilder.maxFragmentSize.|(){}[0] + final fun (kotlin/Int) // io.rsocket.kotlin.core/RSocketServerBuilder.maxFragmentSize.|(kotlin.Int){}[0] + + final fun interceptors(kotlin/Function1) // io.rsocket.kotlin.core/RSocketServerBuilder.interceptors|interceptors(kotlin.Function1){}[0] +} + +final class io.rsocket.kotlin.core/ReservedMimeType : io.rsocket.kotlin.core/MimeTypeWithId { // io.rsocket.kotlin.core/ReservedMimeType|null[0] + constructor (kotlin/Byte) // io.rsocket.kotlin.core/ReservedMimeType.|(kotlin.Byte){}[0] + + final val identifier // io.rsocket.kotlin.core/ReservedMimeType.identifier|{}identifier[0] + final fun (): kotlin/Byte // io.rsocket.kotlin.core/ReservedMimeType.identifier.|(){}[0] + + final fun component1(): kotlin/Byte // io.rsocket.kotlin.core/ReservedMimeType.component1|component1(){}[0] + final fun copy(kotlin/Byte = ...): io.rsocket.kotlin.core/ReservedMimeType // io.rsocket.kotlin.core/ReservedMimeType.copy|copy(kotlin.Byte){}[0] + final fun equals(kotlin/Any?): kotlin/Boolean // io.rsocket.kotlin.core/ReservedMimeType.equals|equals(kotlin.Any?){}[0] + final fun hashCode(): kotlin/Int // io.rsocket.kotlin.core/ReservedMimeType.hashCode|hashCode(){}[0] + final fun toString(): kotlin/String // io.rsocket.kotlin.core/ReservedMimeType.toString|toString(){}[0] +} + +final class io.rsocket.kotlin.keepalive/KeepAlive { // io.rsocket.kotlin.keepalive/KeepAlive|null[0] + constructor (kotlin/Int = ..., kotlin/Int = ...) // io.rsocket.kotlin.keepalive/KeepAlive.|(kotlin.Int;kotlin.Int){}[0] + + final val intervalMillis // io.rsocket.kotlin.keepalive/KeepAlive.intervalMillis|{}intervalMillis[0] + final fun (): kotlin/Int // io.rsocket.kotlin.keepalive/KeepAlive.intervalMillis.|(){}[0] + final val maxLifetimeMillis // io.rsocket.kotlin.keepalive/KeepAlive.maxLifetimeMillis|{}maxLifetimeMillis[0] + final fun (): kotlin/Int // io.rsocket.kotlin.keepalive/KeepAlive.maxLifetimeMillis.|(){}[0] +} + +final class io.rsocket.kotlin.logging/PrintLogger : io.rsocket.kotlin.logging/Logger { // io.rsocket.kotlin.logging/PrintLogger|null[0] + constructor (kotlin/String, io.rsocket.kotlin.logging/LoggingLevel = ...) // io.rsocket.kotlin.logging/PrintLogger.|(kotlin.String;io.rsocket.kotlin.logging.LoggingLevel){}[0] + + final val tag // io.rsocket.kotlin.logging/PrintLogger.tag|{}tag[0] + final fun (): kotlin/String // io.rsocket.kotlin.logging/PrintLogger.tag.|(){}[0] + + final fun isLoggable(io.rsocket.kotlin.logging/LoggingLevel): kotlin/Boolean // io.rsocket.kotlin.logging/PrintLogger.isLoggable|isLoggable(io.rsocket.kotlin.logging.LoggingLevel){}[0] + final fun rawLog(io.rsocket.kotlin.logging/LoggingLevel, kotlin/Throwable?, kotlin/Any?) // io.rsocket.kotlin.logging/PrintLogger.rawLog|rawLog(io.rsocket.kotlin.logging.LoggingLevel;kotlin.Throwable?;kotlin.Any?){}[0] + + final object Companion : io.rsocket.kotlin.logging/LoggerFactory { // io.rsocket.kotlin.logging/PrintLogger.Companion|null[0] + final fun logger(kotlin/String): io.rsocket.kotlin.logging/Logger // io.rsocket.kotlin.logging/PrintLogger.Companion.logger|logger(kotlin.String){}[0] + final fun withLevel(io.rsocket.kotlin.logging/LoggingLevel): io.rsocket.kotlin.logging/LoggerFactory // io.rsocket.kotlin.logging/PrintLogger.Companion.withLevel|withLevel(io.rsocket.kotlin.logging.LoggingLevel){}[0] + } +} + +final class io.rsocket.kotlin.metadata.security/BearerAuthMetadata : io.rsocket.kotlin.metadata.security/AuthMetadata { // io.rsocket.kotlin.metadata.security/BearerAuthMetadata|null[0] + constructor (kotlin/String) // io.rsocket.kotlin.metadata.security/BearerAuthMetadata.|(kotlin.String){}[0] + + final val token // io.rsocket.kotlin.metadata.security/BearerAuthMetadata.token|{}token[0] + final fun (): kotlin/String // io.rsocket.kotlin.metadata.security/BearerAuthMetadata.token.|(){}[0] + final val type // io.rsocket.kotlin.metadata.security/BearerAuthMetadata.type|{}type[0] + final fun (): io.rsocket.kotlin.metadata.security/AuthType // io.rsocket.kotlin.metadata.security/BearerAuthMetadata.type.|(){}[0] + + final fun (kotlinx.io/Sink).writeContent() // io.rsocket.kotlin.metadata.security/BearerAuthMetadata.writeContent|writeContent@kotlinx.io.Sink(){}[0] + final fun close() // io.rsocket.kotlin.metadata.security/BearerAuthMetadata.close|close(){}[0] + + final object Reader : io.rsocket.kotlin.metadata.security/AuthMetadataReader { // io.rsocket.kotlin.metadata.security/BearerAuthMetadata.Reader|null[0] + final fun (kotlinx.io/Source).readContent(io.rsocket.kotlin.metadata.security/AuthType): io.rsocket.kotlin.metadata.security/BearerAuthMetadata // io.rsocket.kotlin.metadata.security/BearerAuthMetadata.Reader.readContent|readContent@kotlinx.io.Source(io.rsocket.kotlin.metadata.security.AuthType){}[0] + } +} + +final class io.rsocket.kotlin.metadata.security/CustomAuthType : io.rsocket.kotlin.metadata.security/AuthTypeWithName { // io.rsocket.kotlin.metadata.security/CustomAuthType|null[0] + constructor (kotlin/String) // io.rsocket.kotlin.metadata.security/CustomAuthType.|(kotlin.String){}[0] + + final val text // io.rsocket.kotlin.metadata.security/CustomAuthType.text|{}text[0] + final fun (): kotlin/String // io.rsocket.kotlin.metadata.security/CustomAuthType.text.|(){}[0] + + final fun component1(): kotlin/String // io.rsocket.kotlin.metadata.security/CustomAuthType.component1|component1(){}[0] + final fun copy(kotlin/String = ...): io.rsocket.kotlin.metadata.security/CustomAuthType // io.rsocket.kotlin.metadata.security/CustomAuthType.copy|copy(kotlin.String){}[0] + final fun equals(kotlin/Any?): kotlin/Boolean // io.rsocket.kotlin.metadata.security/CustomAuthType.equals|equals(kotlin.Any?){}[0] + final fun hashCode(): kotlin/Int // io.rsocket.kotlin.metadata.security/CustomAuthType.hashCode|hashCode(){}[0] + final fun toString(): kotlin/String // io.rsocket.kotlin.metadata.security/CustomAuthType.toString|toString(){}[0] +} + +final class io.rsocket.kotlin.metadata.security/RawAuthMetadata : io.rsocket.kotlin.metadata.security/AuthMetadata { // io.rsocket.kotlin.metadata.security/RawAuthMetadata|null[0] + constructor (io.rsocket.kotlin.metadata.security/AuthType, kotlinx.io/Source) // io.rsocket.kotlin.metadata.security/RawAuthMetadata.|(io.rsocket.kotlin.metadata.security.AuthType;kotlinx.io.Source){}[0] + + final val content // io.rsocket.kotlin.metadata.security/RawAuthMetadata.content|{}content[0] + final fun (): kotlinx.io/Source // io.rsocket.kotlin.metadata.security/RawAuthMetadata.content.|(){}[0] + final val type // io.rsocket.kotlin.metadata.security/RawAuthMetadata.type|{}type[0] + final fun (): io.rsocket.kotlin.metadata.security/AuthType // io.rsocket.kotlin.metadata.security/RawAuthMetadata.type.|(){}[0] + + final fun (kotlinx.io/Sink).writeContent() // io.rsocket.kotlin.metadata.security/RawAuthMetadata.writeContent|writeContent@kotlinx.io.Sink(){}[0] + final fun close() // io.rsocket.kotlin.metadata.security/RawAuthMetadata.close|close(){}[0] + + final object Reader : io.rsocket.kotlin.metadata.security/AuthMetadataReader { // io.rsocket.kotlin.metadata.security/RawAuthMetadata.Reader|null[0] + final fun (kotlinx.io/Source).readContent(io.rsocket.kotlin.metadata.security/AuthType): io.rsocket.kotlin.metadata.security/RawAuthMetadata // io.rsocket.kotlin.metadata.security/RawAuthMetadata.Reader.readContent|readContent@kotlinx.io.Source(io.rsocket.kotlin.metadata.security.AuthType){}[0] + } +} + +final class io.rsocket.kotlin.metadata.security/ReservedAuthType : io.rsocket.kotlin.metadata.security/AuthTypeWithId { // io.rsocket.kotlin.metadata.security/ReservedAuthType|null[0] + constructor (kotlin/Byte) // io.rsocket.kotlin.metadata.security/ReservedAuthType.|(kotlin.Byte){}[0] + + final val identifier // io.rsocket.kotlin.metadata.security/ReservedAuthType.identifier|{}identifier[0] + final fun (): kotlin/Byte // io.rsocket.kotlin.metadata.security/ReservedAuthType.identifier.|(){}[0] + + final fun component1(): kotlin/Byte // io.rsocket.kotlin.metadata.security/ReservedAuthType.component1|component1(){}[0] + final fun copy(kotlin/Byte = ...): io.rsocket.kotlin.metadata.security/ReservedAuthType // io.rsocket.kotlin.metadata.security/ReservedAuthType.copy|copy(kotlin.Byte){}[0] + final fun equals(kotlin/Any?): kotlin/Boolean // io.rsocket.kotlin.metadata.security/ReservedAuthType.equals|equals(kotlin.Any?){}[0] + final fun hashCode(): kotlin/Int // io.rsocket.kotlin.metadata.security/ReservedAuthType.hashCode|hashCode(){}[0] + final fun toString(): kotlin/String // io.rsocket.kotlin.metadata.security/ReservedAuthType.toString|toString(){}[0] +} + +final class io.rsocket.kotlin.metadata.security/SimpleAuthMetadata : io.rsocket.kotlin.metadata.security/AuthMetadata { // io.rsocket.kotlin.metadata.security/SimpleAuthMetadata|null[0] + constructor (kotlin/String, kotlin/String) // io.rsocket.kotlin.metadata.security/SimpleAuthMetadata.|(kotlin.String;kotlin.String){}[0] + + final val password // io.rsocket.kotlin.metadata.security/SimpleAuthMetadata.password|{}password[0] + final fun (): kotlin/String // io.rsocket.kotlin.metadata.security/SimpleAuthMetadata.password.|(){}[0] + final val type // io.rsocket.kotlin.metadata.security/SimpleAuthMetadata.type|{}type[0] + final fun (): io.rsocket.kotlin.metadata.security/AuthType // io.rsocket.kotlin.metadata.security/SimpleAuthMetadata.type.|(){}[0] + final val username // io.rsocket.kotlin.metadata.security/SimpleAuthMetadata.username|{}username[0] + final fun (): kotlin/String // io.rsocket.kotlin.metadata.security/SimpleAuthMetadata.username.|(){}[0] + + final fun (kotlinx.io/Sink).writeContent() // io.rsocket.kotlin.metadata.security/SimpleAuthMetadata.writeContent|writeContent@kotlinx.io.Sink(){}[0] + final fun close() // io.rsocket.kotlin.metadata.security/SimpleAuthMetadata.close|close(){}[0] + + final object Reader : io.rsocket.kotlin.metadata.security/AuthMetadataReader { // io.rsocket.kotlin.metadata.security/SimpleAuthMetadata.Reader|null[0] + final fun (kotlinx.io/Source).readContent(io.rsocket.kotlin.metadata.security/AuthType): io.rsocket.kotlin.metadata.security/SimpleAuthMetadata // io.rsocket.kotlin.metadata.security/SimpleAuthMetadata.Reader.readContent|readContent@kotlinx.io.Source(io.rsocket.kotlin.metadata.security.AuthType){}[0] + } +} + +final class io.rsocket.kotlin.metadata/CompositeMetadataFromBuilder : io.rsocket.kotlin.metadata/CompositeMetadata, io.rsocket.kotlin.metadata/CompositeMetadataBuilder { // io.rsocket.kotlin.metadata/CompositeMetadataFromBuilder|null[0] + constructor () // io.rsocket.kotlin.metadata/CompositeMetadataFromBuilder.|(){}[0] + + final val entries // io.rsocket.kotlin.metadata/CompositeMetadataFromBuilder.entries|{}entries[0] + final fun (): kotlin.collections/List // io.rsocket.kotlin.metadata/CompositeMetadataFromBuilder.entries.|(){}[0] + + final fun add(io.rsocket.kotlin.core/MimeType, kotlinx.io/Buffer) // io.rsocket.kotlin.metadata/CompositeMetadataFromBuilder.add|add(io.rsocket.kotlin.core.MimeType;kotlinx.io.Buffer){}[0] + final fun add(io.rsocket.kotlin.metadata/Metadata) // io.rsocket.kotlin.metadata/CompositeMetadataFromBuilder.add|add(io.rsocket.kotlin.metadata.Metadata){}[0] +} + +final class io.rsocket.kotlin.metadata/PerStreamAcceptableDataMimeTypesMetadata : io.rsocket.kotlin.metadata/Metadata { // io.rsocket.kotlin.metadata/PerStreamAcceptableDataMimeTypesMetadata|null[0] + constructor (kotlin.collections/List) // io.rsocket.kotlin.metadata/PerStreamAcceptableDataMimeTypesMetadata.|(kotlin.collections.List){}[0] + + final val mimeType // io.rsocket.kotlin.metadata/PerStreamAcceptableDataMimeTypesMetadata.mimeType|{}mimeType[0] + final fun (): io.rsocket.kotlin.core/MimeType // io.rsocket.kotlin.metadata/PerStreamAcceptableDataMimeTypesMetadata.mimeType.|(){}[0] + final val types // io.rsocket.kotlin.metadata/PerStreamAcceptableDataMimeTypesMetadata.types|{}types[0] + final fun (): kotlin.collections/List // io.rsocket.kotlin.metadata/PerStreamAcceptableDataMimeTypesMetadata.types.|(){}[0] + + final fun (kotlinx.io/Sink).writeSelf() // io.rsocket.kotlin.metadata/PerStreamAcceptableDataMimeTypesMetadata.writeSelf|writeSelf@kotlinx.io.Sink(){}[0] + final fun close() // io.rsocket.kotlin.metadata/PerStreamAcceptableDataMimeTypesMetadata.close|close(){}[0] + + final object Reader : io.rsocket.kotlin.metadata/MetadataReader { // io.rsocket.kotlin.metadata/PerStreamAcceptableDataMimeTypesMetadata.Reader|null[0] + final val mimeType // io.rsocket.kotlin.metadata/PerStreamAcceptableDataMimeTypesMetadata.Reader.mimeType|{}mimeType[0] + final fun (): io.rsocket.kotlin.core/MimeType // io.rsocket.kotlin.metadata/PerStreamAcceptableDataMimeTypesMetadata.Reader.mimeType.|(){}[0] + + final fun (kotlinx.io/Source).read(): io.rsocket.kotlin.metadata/PerStreamAcceptableDataMimeTypesMetadata // io.rsocket.kotlin.metadata/PerStreamAcceptableDataMimeTypesMetadata.Reader.read|read@kotlinx.io.Source(){}[0] + } +} + +final class io.rsocket.kotlin.metadata/PerStreamDataMimeTypeMetadata : io.rsocket.kotlin.metadata/Metadata { // io.rsocket.kotlin.metadata/PerStreamDataMimeTypeMetadata|null[0] + constructor (io.rsocket.kotlin.core/MimeType) // io.rsocket.kotlin.metadata/PerStreamDataMimeTypeMetadata.|(io.rsocket.kotlin.core.MimeType){}[0] + + final val mimeType // io.rsocket.kotlin.metadata/PerStreamDataMimeTypeMetadata.mimeType|{}mimeType[0] + final fun (): io.rsocket.kotlin.core/MimeType // io.rsocket.kotlin.metadata/PerStreamDataMimeTypeMetadata.mimeType.|(){}[0] + final val type // io.rsocket.kotlin.metadata/PerStreamDataMimeTypeMetadata.type|{}type[0] + final fun (): io.rsocket.kotlin.core/MimeType // io.rsocket.kotlin.metadata/PerStreamDataMimeTypeMetadata.type.|(){}[0] + + final fun (kotlinx.io/Sink).writeSelf() // io.rsocket.kotlin.metadata/PerStreamDataMimeTypeMetadata.writeSelf|writeSelf@kotlinx.io.Sink(){}[0] + final fun close() // io.rsocket.kotlin.metadata/PerStreamDataMimeTypeMetadata.close|close(){}[0] + + final object Reader : io.rsocket.kotlin.metadata/MetadataReader { // io.rsocket.kotlin.metadata/PerStreamDataMimeTypeMetadata.Reader|null[0] + final val mimeType // io.rsocket.kotlin.metadata/PerStreamDataMimeTypeMetadata.Reader.mimeType|{}mimeType[0] + final fun (): io.rsocket.kotlin.core/MimeType // io.rsocket.kotlin.metadata/PerStreamDataMimeTypeMetadata.Reader.mimeType.|(){}[0] + + final fun (kotlinx.io/Source).read(): io.rsocket.kotlin.metadata/PerStreamDataMimeTypeMetadata // io.rsocket.kotlin.metadata/PerStreamDataMimeTypeMetadata.Reader.read|read@kotlinx.io.Source(){}[0] + } +} + +final class io.rsocket.kotlin.metadata/RawMetadata : io.rsocket.kotlin.metadata/Metadata { // io.rsocket.kotlin.metadata/RawMetadata|null[0] + constructor (io.rsocket.kotlin.core/MimeType, kotlinx.io/Source) // io.rsocket.kotlin.metadata/RawMetadata.|(io.rsocket.kotlin.core.MimeType;kotlinx.io.Source){}[0] + + final val content // io.rsocket.kotlin.metadata/RawMetadata.content|{}content[0] + final fun (): kotlinx.io/Source // io.rsocket.kotlin.metadata/RawMetadata.content.|(){}[0] + final val mimeType // io.rsocket.kotlin.metadata/RawMetadata.mimeType|{}mimeType[0] + final fun (): io.rsocket.kotlin.core/MimeType // io.rsocket.kotlin.metadata/RawMetadata.mimeType.|(){}[0] + + final fun (kotlinx.io/Sink).writeSelf() // io.rsocket.kotlin.metadata/RawMetadata.writeSelf|writeSelf@kotlinx.io.Sink(){}[0] + final fun close() // io.rsocket.kotlin.metadata/RawMetadata.close|close(){}[0] + + final object Companion { // io.rsocket.kotlin.metadata/RawMetadata.Companion|null[0] + final fun reader(io.rsocket.kotlin.core/MimeType): io.rsocket.kotlin.metadata/MetadataReader // io.rsocket.kotlin.metadata/RawMetadata.Companion.reader|reader(io.rsocket.kotlin.core.MimeType){}[0] + } +} + +final class io.rsocket.kotlin.metadata/RoutingMetadata : io.rsocket.kotlin.metadata/Metadata { // io.rsocket.kotlin.metadata/RoutingMetadata|null[0] + constructor (kotlin.collections/List) // io.rsocket.kotlin.metadata/RoutingMetadata.|(kotlin.collections.List){}[0] + + final val mimeType // io.rsocket.kotlin.metadata/RoutingMetadata.mimeType|{}mimeType[0] + final fun (): io.rsocket.kotlin.core/MimeType // io.rsocket.kotlin.metadata/RoutingMetadata.mimeType.|(){}[0] + final val tags // io.rsocket.kotlin.metadata/RoutingMetadata.tags|{}tags[0] + final fun (): kotlin.collections/List // io.rsocket.kotlin.metadata/RoutingMetadata.tags.|(){}[0] + + final fun (kotlinx.io/Sink).writeSelf() // io.rsocket.kotlin.metadata/RoutingMetadata.writeSelf|writeSelf@kotlinx.io.Sink(){}[0] + final fun close() // io.rsocket.kotlin.metadata/RoutingMetadata.close|close(){}[0] + + final object Reader : io.rsocket.kotlin.metadata/MetadataReader { // io.rsocket.kotlin.metadata/RoutingMetadata.Reader|null[0] + final val mimeType // io.rsocket.kotlin.metadata/RoutingMetadata.Reader.mimeType|{}mimeType[0] + final fun (): io.rsocket.kotlin.core/MimeType // io.rsocket.kotlin.metadata/RoutingMetadata.Reader.mimeType.|(){}[0] + + final fun (kotlinx.io/Source).read(): io.rsocket.kotlin.metadata/RoutingMetadata // io.rsocket.kotlin.metadata/RoutingMetadata.Reader.read|read@kotlinx.io.Source(){}[0] + } +} + +final class io.rsocket.kotlin.metadata/ZipkinTracingMetadata : io.rsocket.kotlin.metadata/Metadata { // io.rsocket.kotlin.metadata/ZipkinTracingMetadata|null[0] + final val extendedTraceId // io.rsocket.kotlin.metadata/ZipkinTracingMetadata.extendedTraceId|{}extendedTraceId[0] + final fun (): kotlin/Boolean // io.rsocket.kotlin.metadata/ZipkinTracingMetadata.extendedTraceId.|(){}[0] + final val hasIds // io.rsocket.kotlin.metadata/ZipkinTracingMetadata.hasIds|{}hasIds[0] + final fun (): kotlin/Boolean // io.rsocket.kotlin.metadata/ZipkinTracingMetadata.hasIds.|(){}[0] + final val hasParentSpanId // io.rsocket.kotlin.metadata/ZipkinTracingMetadata.hasParentSpanId|{}hasParentSpanId[0] + final fun (): kotlin/Boolean // io.rsocket.kotlin.metadata/ZipkinTracingMetadata.hasParentSpanId.|(){}[0] + final val kind // io.rsocket.kotlin.metadata/ZipkinTracingMetadata.kind|{}kind[0] + final fun (): io.rsocket.kotlin.metadata/ZipkinTracingMetadata.Kind // io.rsocket.kotlin.metadata/ZipkinTracingMetadata.kind.|(){}[0] + final val mimeType // io.rsocket.kotlin.metadata/ZipkinTracingMetadata.mimeType|{}mimeType[0] + final fun (): io.rsocket.kotlin.core/MimeType // io.rsocket.kotlin.metadata/ZipkinTracingMetadata.mimeType.|(){}[0] + final val parentSpanId // io.rsocket.kotlin.metadata/ZipkinTracingMetadata.parentSpanId|{}parentSpanId[0] + final fun (): kotlin/Long // io.rsocket.kotlin.metadata/ZipkinTracingMetadata.parentSpanId.|(){}[0] + final val spanId // io.rsocket.kotlin.metadata/ZipkinTracingMetadata.spanId|{}spanId[0] + final fun (): kotlin/Long // io.rsocket.kotlin.metadata/ZipkinTracingMetadata.spanId.|(){}[0] + final val traceId // io.rsocket.kotlin.metadata/ZipkinTracingMetadata.traceId|{}traceId[0] + final fun (): kotlin/Long // io.rsocket.kotlin.metadata/ZipkinTracingMetadata.traceId.|(){}[0] + final val traceIdHigh // io.rsocket.kotlin.metadata/ZipkinTracingMetadata.traceIdHigh|{}traceIdHigh[0] + final fun (): kotlin/Long // io.rsocket.kotlin.metadata/ZipkinTracingMetadata.traceIdHigh.|(){}[0] + + final fun (kotlinx.io/Sink).writeSelf() // io.rsocket.kotlin.metadata/ZipkinTracingMetadata.writeSelf|writeSelf@kotlinx.io.Sink(){}[0] + final fun close() // io.rsocket.kotlin.metadata/ZipkinTracingMetadata.close|close(){}[0] + + final enum class Kind : kotlin/Enum { // io.rsocket.kotlin.metadata/ZipkinTracingMetadata.Kind|null[0] + enum entry Debug // io.rsocket.kotlin.metadata/ZipkinTracingMetadata.Kind.Debug|null[0] + enum entry NotSampled // io.rsocket.kotlin.metadata/ZipkinTracingMetadata.Kind.NotSampled|null[0] + enum entry Sample // io.rsocket.kotlin.metadata/ZipkinTracingMetadata.Kind.Sample|null[0] + enum entry Unspecified // io.rsocket.kotlin.metadata/ZipkinTracingMetadata.Kind.Unspecified|null[0] + + final val entries // io.rsocket.kotlin.metadata/ZipkinTracingMetadata.Kind.entries|#static{}entries[0] + final fun (): kotlin.enums/EnumEntries // io.rsocket.kotlin.metadata/ZipkinTracingMetadata.Kind.entries.|#static(){}[0] + + final fun valueOf(kotlin/String): io.rsocket.kotlin.metadata/ZipkinTracingMetadata.Kind // io.rsocket.kotlin.metadata/ZipkinTracingMetadata.Kind.valueOf|valueOf#static(kotlin.String){}[0] + final fun values(): kotlin/Array // io.rsocket.kotlin.metadata/ZipkinTracingMetadata.Kind.values|values#static(){}[0] + } + + final object Reader : io.rsocket.kotlin.metadata/MetadataReader { // io.rsocket.kotlin.metadata/ZipkinTracingMetadata.Reader|null[0] + final val mimeType // io.rsocket.kotlin.metadata/ZipkinTracingMetadata.Reader.mimeType|{}mimeType[0] + final fun (): io.rsocket.kotlin.core/MimeType // io.rsocket.kotlin.metadata/ZipkinTracingMetadata.Reader.mimeType.|(){}[0] + + final fun (kotlinx.io/Source).read(): io.rsocket.kotlin.metadata/ZipkinTracingMetadata // io.rsocket.kotlin.metadata/ZipkinTracingMetadata.Reader.read|read@kotlinx.io.Source(){}[0] + } +} + +final class io.rsocket.kotlin.payload/PayloadFromBuilder : io.rsocket.kotlin.payload/Payload, io.rsocket.kotlin.payload/PayloadBuilder { // io.rsocket.kotlin.payload/PayloadFromBuilder|null[0] + constructor () // io.rsocket.kotlin.payload/PayloadFromBuilder.|(){}[0] + + final var data // io.rsocket.kotlin.payload/PayloadFromBuilder.data|{}data[0] + final fun (): kotlinx.io/Buffer // io.rsocket.kotlin.payload/PayloadFromBuilder.data.|(){}[0] + final var metadata // io.rsocket.kotlin.payload/PayloadFromBuilder.metadata|{}metadata[0] + final fun (): kotlinx.io/Buffer? // io.rsocket.kotlin.payload/PayloadFromBuilder.metadata.|(){}[0] + + final fun build(): io.rsocket.kotlin.payload/Payload // io.rsocket.kotlin.payload/PayloadFromBuilder.build|build(){}[0] + final fun data(kotlinx.io/Buffer) // io.rsocket.kotlin.payload/PayloadFromBuilder.data|data(kotlinx.io.Buffer){}[0] + final fun metadata(kotlinx.io/Buffer) // io.rsocket.kotlin.payload/PayloadFromBuilder.metadata|metadata(kotlinx.io.Buffer){}[0] +} + +final class io.rsocket.kotlin.payload/PayloadMimeType { // io.rsocket.kotlin.payload/PayloadMimeType|null[0] + constructor (kotlin/String, kotlin/String) // io.rsocket.kotlin.payload/PayloadMimeType.|(kotlin.String;kotlin.String){}[0] + + final val data // io.rsocket.kotlin.payload/PayloadMimeType.data|{}data[0] + final fun (): kotlin/String // io.rsocket.kotlin.payload/PayloadMimeType.data.|(){}[0] + final val metadata // io.rsocket.kotlin.payload/PayloadMimeType.metadata|{}metadata[0] + final fun (): kotlin/String // io.rsocket.kotlin.payload/PayloadMimeType.metadata.|(){}[0] +} + +final class io.rsocket.kotlin.transport.internal/PrioritizationFrameQueue { // io.rsocket.kotlin.transport.internal/PrioritizationFrameQueue|null[0] + constructor () // io.rsocket.kotlin.transport.internal/PrioritizationFrameQueue.|(){}[0] + + final val isClosedForSend // io.rsocket.kotlin.transport.internal/PrioritizationFrameQueue.isClosedForSend|{}isClosedForSend[0] + final fun (): kotlin/Boolean // io.rsocket.kotlin.transport.internal/PrioritizationFrameQueue.isClosedForSend.|(){}[0] + + final fun cancel() // io.rsocket.kotlin.transport.internal/PrioritizationFrameQueue.cancel|cancel(){}[0] + final fun close() // io.rsocket.kotlin.transport.internal/PrioritizationFrameQueue.close|close(){}[0] + final fun tryDequeueFrame(): kotlinx.io/Buffer? // io.rsocket.kotlin.transport.internal/PrioritizationFrameQueue.tryDequeueFrame|tryDequeueFrame(){}[0] + final suspend fun dequeueFrame(): kotlinx.io/Buffer? // io.rsocket.kotlin.transport.internal/PrioritizationFrameQueue.dequeueFrame|dequeueFrame(){}[0] + final suspend fun enqueueFrame(kotlin/Int, kotlinx.io/Buffer) // io.rsocket.kotlin.transport.internal/PrioritizationFrameQueue.enqueueFrame|enqueueFrame(kotlin.Int;kotlinx.io.Buffer){}[0] +} + +final class io.rsocket.kotlin/ChannelStrategy : io.rsocket.kotlin/RequestStrategy, io.rsocket.kotlin/RequestStrategy.Element { // io.rsocket.kotlin/ChannelStrategy|null[0] + constructor (kotlinx.coroutines.channels/ReceiveChannel) // io.rsocket.kotlin/ChannelStrategy.|(kotlinx.coroutines.channels.ReceiveChannel){}[0] + + final fun provide(): io.rsocket.kotlin/RequestStrategy.Element // io.rsocket.kotlin/ChannelStrategy.provide|provide(){}[0] + final suspend fun firstRequest(): kotlin/Int // io.rsocket.kotlin/ChannelStrategy.firstRequest|firstRequest(){}[0] + final suspend fun nextRequest(): kotlin/Int // io.rsocket.kotlin/ChannelStrategy.nextRequest|nextRequest(){}[0] +} + +final class io.rsocket.kotlin/ConnectionAcceptorContext { // io.rsocket.kotlin/ConnectionAcceptorContext|null[0] + final val config // io.rsocket.kotlin/ConnectionAcceptorContext.config|{}config[0] + final fun (): io.rsocket.kotlin/ConnectionConfig // io.rsocket.kotlin/ConnectionAcceptorContext.config.|(){}[0] + final val requester // io.rsocket.kotlin/ConnectionAcceptorContext.requester|{}requester[0] + final fun (): io.rsocket.kotlin/RSocket // io.rsocket.kotlin/ConnectionAcceptorContext.requester.|(){}[0] +} + +final class io.rsocket.kotlin/ConnectionConfig { // io.rsocket.kotlin/ConnectionConfig|null[0] + final val keepAlive // io.rsocket.kotlin/ConnectionConfig.keepAlive|{}keepAlive[0] + final fun (): io.rsocket.kotlin.keepalive/KeepAlive // io.rsocket.kotlin/ConnectionConfig.keepAlive.|(){}[0] + final val payloadMimeType // io.rsocket.kotlin/ConnectionConfig.payloadMimeType|{}payloadMimeType[0] + final fun (): io.rsocket.kotlin.payload/PayloadMimeType // io.rsocket.kotlin/ConnectionConfig.payloadMimeType.|(){}[0] + final val setupPayload // io.rsocket.kotlin/ConnectionConfig.setupPayload|{}setupPayload[0] + final fun (): io.rsocket.kotlin.payload/Payload // io.rsocket.kotlin/ConnectionConfig.setupPayload.|(){}[0] +} + +final class io.rsocket.kotlin/PrefetchStrategy : io.rsocket.kotlin/RequestStrategy { // io.rsocket.kotlin/PrefetchStrategy|null[0] + constructor (kotlin/Int, kotlin/Int) // io.rsocket.kotlin/PrefetchStrategy.|(kotlin.Int;kotlin.Int){}[0] + + final fun provide(): io.rsocket.kotlin/RequestStrategy.Element // io.rsocket.kotlin/PrefetchStrategy.provide|provide(){}[0] +} + +final class io.rsocket.kotlin/RSocketRequestHandlerBuilder { // io.rsocket.kotlin/RSocketRequestHandlerBuilder|null[0] + final fun fireAndForget(kotlin.coroutines/SuspendFunction2) // io.rsocket.kotlin/RSocketRequestHandlerBuilder.fireAndForget|fireAndForget(kotlin.coroutines.SuspendFunction2){}[0] + final fun metadataPush(kotlin.coroutines/SuspendFunction2) // io.rsocket.kotlin/RSocketRequestHandlerBuilder.metadataPush|metadataPush(kotlin.coroutines.SuspendFunction2){}[0] + final fun requestChannel(kotlin.coroutines/SuspendFunction3, kotlinx.coroutines.flow/Flow>) // io.rsocket.kotlin/RSocketRequestHandlerBuilder.requestChannel|requestChannel(kotlin.coroutines.SuspendFunction3,kotlinx.coroutines.flow.Flow>){}[0] + final fun requestResponse(kotlin.coroutines/SuspendFunction2) // io.rsocket.kotlin/RSocketRequestHandlerBuilder.requestResponse|requestResponse(kotlin.coroutines.SuspendFunction2){}[0] + final fun requestStream(kotlin.coroutines/SuspendFunction2>) // io.rsocket.kotlin/RSocketRequestHandlerBuilder.requestStream|requestStream(kotlin.coroutines.SuspendFunction2>){}[0] +} + +sealed class io.rsocket.kotlin/RSocketError : kotlin/Throwable { // io.rsocket.kotlin/RSocketError|null[0] + final val errorCode // io.rsocket.kotlin/RSocketError.errorCode|{}errorCode[0] + final fun (): kotlin/Int // io.rsocket.kotlin/RSocketError.errorCode.|(){}[0] + + final class ApplicationError : io.rsocket.kotlin/RSocketError { // io.rsocket.kotlin/RSocketError.ApplicationError|null[0] + constructor (kotlin/String) // io.rsocket.kotlin/RSocketError.ApplicationError.|(kotlin.String){}[0] + } + + final class Canceled : io.rsocket.kotlin/RSocketError { // io.rsocket.kotlin/RSocketError.Canceled|null[0] + constructor (kotlin/String) // io.rsocket.kotlin/RSocketError.Canceled.|(kotlin.String){}[0] + } + + final class ConnectionClose : io.rsocket.kotlin/RSocketError { // io.rsocket.kotlin/RSocketError.ConnectionClose|null[0] + constructor (kotlin/String) // io.rsocket.kotlin/RSocketError.ConnectionClose.|(kotlin.String){}[0] + } + + final class ConnectionError : io.rsocket.kotlin/RSocketError { // io.rsocket.kotlin/RSocketError.ConnectionError|null[0] + constructor (kotlin/String) // io.rsocket.kotlin/RSocketError.ConnectionError.|(kotlin.String){}[0] + } + + final class Custom : io.rsocket.kotlin/RSocketError { // io.rsocket.kotlin/RSocketError.Custom|null[0] + constructor (kotlin/Int, kotlin/String) // io.rsocket.kotlin/RSocketError.Custom.|(kotlin.Int;kotlin.String){}[0] + + final object Companion { // io.rsocket.kotlin/RSocketError.Custom.Companion|null[0] + final const val MaxAllowedCode // io.rsocket.kotlin/RSocketError.Custom.Companion.MaxAllowedCode|{}MaxAllowedCode[0] + final fun (): kotlin/Int // io.rsocket.kotlin/RSocketError.Custom.Companion.MaxAllowedCode.|(){}[0] + final const val MinAllowedCode // io.rsocket.kotlin/RSocketError.Custom.Companion.MinAllowedCode|{}MinAllowedCode[0] + final fun (): kotlin/Int // io.rsocket.kotlin/RSocketError.Custom.Companion.MinAllowedCode.|(){}[0] + + final fun checkCodeInAllowedRange(kotlin/Int): kotlin/Boolean // io.rsocket.kotlin/RSocketError.Custom.Companion.checkCodeInAllowedRange|checkCodeInAllowedRange(kotlin.Int){}[0] + } + } + + final class Invalid : io.rsocket.kotlin/RSocketError { // io.rsocket.kotlin/RSocketError.Invalid|null[0] + constructor (kotlin/String) // io.rsocket.kotlin/RSocketError.Invalid.|(kotlin.String){}[0] + } + + final class Rejected : io.rsocket.kotlin/RSocketError { // io.rsocket.kotlin/RSocketError.Rejected|null[0] + constructor (kotlin/String) // io.rsocket.kotlin/RSocketError.Rejected.|(kotlin.String){}[0] + } + + final class RejectedResume : io.rsocket.kotlin/RSocketError { // io.rsocket.kotlin/RSocketError.RejectedResume|null[0] + constructor (kotlin/String) // io.rsocket.kotlin/RSocketError.RejectedResume.|(kotlin.String){}[0] + } + + sealed class Setup : io.rsocket.kotlin/RSocketError { // io.rsocket.kotlin/RSocketError.Setup|null[0] + final class Invalid : io.rsocket.kotlin/RSocketError.Setup { // io.rsocket.kotlin/RSocketError.Setup.Invalid|null[0] + constructor (kotlin/String) // io.rsocket.kotlin/RSocketError.Setup.Invalid.|(kotlin.String){}[0] + } + + final class Rejected : io.rsocket.kotlin/RSocketError.Setup { // io.rsocket.kotlin/RSocketError.Setup.Rejected|null[0] + constructor (kotlin/String) // io.rsocket.kotlin/RSocketError.Setup.Rejected.|(kotlin.String){}[0] + } + + final class Unsupported : io.rsocket.kotlin/RSocketError.Setup { // io.rsocket.kotlin/RSocketError.Setup.Unsupported|null[0] + constructor (kotlin/String) // io.rsocket.kotlin/RSocketError.Setup.Unsupported.|(kotlin.String){}[0] + } + } +} + +final object io.rsocket.kotlin.logging/NoopLogger : io.rsocket.kotlin.logging/Logger, io.rsocket.kotlin.logging/LoggerFactory { // io.rsocket.kotlin.logging/NoopLogger|null[0] + final val tag // io.rsocket.kotlin.logging/NoopLogger.tag|{}tag[0] + final fun (): kotlin/String // io.rsocket.kotlin.logging/NoopLogger.tag.|(){}[0] + + final fun isLoggable(io.rsocket.kotlin.logging/LoggingLevel): kotlin/Boolean // io.rsocket.kotlin.logging/NoopLogger.isLoggable|isLoggable(io.rsocket.kotlin.logging.LoggingLevel){}[0] + final fun logger(kotlin/String): io.rsocket.kotlin.logging/Logger // io.rsocket.kotlin.logging/NoopLogger.logger|logger(kotlin.String){}[0] + final fun rawLog(io.rsocket.kotlin.logging/LoggingLevel, kotlin/Throwable?, kotlin/Any?) // io.rsocket.kotlin.logging/NoopLogger.rawLog|rawLog(io.rsocket.kotlin.logging.LoggingLevel;kotlin.Throwable?;kotlin.Any?){}[0] +} + +final fun (io.rsocket.kotlin.metadata.security/RawAuthMetadata).io.rsocket.kotlin.metadata.security/hasAuthTypeOf(io.rsocket.kotlin.metadata.security/AuthMetadataReader<*>): kotlin/Boolean // io.rsocket.kotlin.metadata.security/hasAuthTypeOf|hasAuthTypeOf@io.rsocket.kotlin.metadata.security.RawAuthMetadata(io.rsocket.kotlin.metadata.security.AuthMetadataReader<*>){}[0] +final fun (io.rsocket.kotlin.metadata/CompositeMetadata).io.rsocket.kotlin.metadata/contains(io.rsocket.kotlin.core/MimeType): kotlin/Boolean // io.rsocket.kotlin.metadata/contains|contains@io.rsocket.kotlin.metadata.CompositeMetadata(io.rsocket.kotlin.core.MimeType){}[0] +final fun (io.rsocket.kotlin.metadata/CompositeMetadata).io.rsocket.kotlin.metadata/contains(io.rsocket.kotlin.metadata/MetadataReader<*>): kotlin/Boolean // io.rsocket.kotlin.metadata/contains|contains@io.rsocket.kotlin.metadata.CompositeMetadata(io.rsocket.kotlin.metadata.MetadataReader<*>){}[0] +final fun (io.rsocket.kotlin.metadata/CompositeMetadata).io.rsocket.kotlin.metadata/get(io.rsocket.kotlin.core/MimeType): kotlinx.io/Source // io.rsocket.kotlin.metadata/get|get@io.rsocket.kotlin.metadata.CompositeMetadata(io.rsocket.kotlin.core.MimeType){}[0] +final fun (io.rsocket.kotlin.metadata/CompositeMetadata).io.rsocket.kotlin.metadata/getOrNull(io.rsocket.kotlin.core/MimeType): kotlinx.io/Source? // io.rsocket.kotlin.metadata/getOrNull|getOrNull@io.rsocket.kotlin.metadata.CompositeMetadata(io.rsocket.kotlin.core.MimeType){}[0] +final fun (io.rsocket.kotlin.metadata/CompositeMetadata).io.rsocket.kotlin.metadata/list(io.rsocket.kotlin.core/MimeType): kotlin.collections/List // io.rsocket.kotlin.metadata/list|list@io.rsocket.kotlin.metadata.CompositeMetadata(io.rsocket.kotlin.core.MimeType){}[0] +final fun (io.rsocket.kotlin.metadata/CompositeMetadata.Entry).io.rsocket.kotlin.metadata/hasMimeTypeOf(io.rsocket.kotlin.metadata/MetadataReader<*>): kotlin/Boolean // io.rsocket.kotlin.metadata/hasMimeTypeOf|hasMimeTypeOf@io.rsocket.kotlin.metadata.CompositeMetadata.Entry(io.rsocket.kotlin.metadata.MetadataReader<*>){}[0] +final fun (io.rsocket.kotlin.metadata/Metadata).io.rsocket.kotlin.metadata/toBuffer(): kotlinx.io/Buffer // io.rsocket.kotlin.metadata/toBuffer|toBuffer@io.rsocket.kotlin.metadata.Metadata(){}[0] +final fun (io.rsocket.kotlin.payload/PayloadBuilder).io.rsocket.kotlin.metadata/metadata(io.rsocket.kotlin.metadata/Metadata) // io.rsocket.kotlin.metadata/metadata|metadata@io.rsocket.kotlin.payload.PayloadBuilder(io.rsocket.kotlin.metadata.Metadata){}[0] +final fun (io.rsocket.kotlin.payload/PayloadBuilder).io.rsocket.kotlin.payload/data(kotlin/ByteArray) // io.rsocket.kotlin.payload/data|data@io.rsocket.kotlin.payload.PayloadBuilder(kotlin.ByteArray){}[0] +final fun (io.rsocket.kotlin.payload/PayloadBuilder).io.rsocket.kotlin.payload/data(kotlin/String) // io.rsocket.kotlin.payload/data|data@io.rsocket.kotlin.payload.PayloadBuilder(kotlin.String){}[0] +final fun (io.rsocket.kotlin.payload/PayloadBuilder).io.rsocket.kotlin.payload/metadata(kotlin/ByteArray) // io.rsocket.kotlin.payload/metadata|metadata@io.rsocket.kotlin.payload.PayloadBuilder(kotlin.ByteArray){}[0] +final fun (io.rsocket.kotlin.payload/PayloadBuilder).io.rsocket.kotlin.payload/metadata(kotlin/String) // io.rsocket.kotlin.payload/metadata|metadata@io.rsocket.kotlin.payload.PayloadBuilder(kotlin.String){}[0] +final fun <#A: io.rsocket.kotlin.metadata.security/AuthMetadata> (io.rsocket.kotlin.metadata.security/RawAuthMetadata).io.rsocket.kotlin.metadata.security/read(io.rsocket.kotlin.metadata.security/AuthMetadataReader<#A>): #A // io.rsocket.kotlin.metadata.security/read|read@io.rsocket.kotlin.metadata.security.RawAuthMetadata(io.rsocket.kotlin.metadata.security.AuthMetadataReader<0:0>){0§}[0] +final fun <#A: io.rsocket.kotlin.metadata.security/AuthMetadata> (io.rsocket.kotlin.metadata.security/RawAuthMetadata).io.rsocket.kotlin.metadata.security/readOrNull(io.rsocket.kotlin.metadata.security/AuthMetadataReader<#A>): #A? // io.rsocket.kotlin.metadata.security/readOrNull|readOrNull@io.rsocket.kotlin.metadata.security.RawAuthMetadata(io.rsocket.kotlin.metadata.security.AuthMetadataReader<0:0>){0§}[0] +final fun <#A: io.rsocket.kotlin.metadata/Metadata> (io.rsocket.kotlin.metadata/CompositeMetadata).io.rsocket.kotlin.metadata/get(io.rsocket.kotlin.metadata/MetadataReader<#A>): #A // io.rsocket.kotlin.metadata/get|get@io.rsocket.kotlin.metadata.CompositeMetadata(io.rsocket.kotlin.metadata.MetadataReader<0:0>){0§}[0] +final fun <#A: io.rsocket.kotlin.metadata/Metadata> (io.rsocket.kotlin.metadata/CompositeMetadata).io.rsocket.kotlin.metadata/getOrNull(io.rsocket.kotlin.metadata/MetadataReader<#A>): #A? // io.rsocket.kotlin.metadata/getOrNull|getOrNull@io.rsocket.kotlin.metadata.CompositeMetadata(io.rsocket.kotlin.metadata.MetadataReader<0:0>){0§}[0] +final fun <#A: io.rsocket.kotlin.metadata/Metadata> (io.rsocket.kotlin.metadata/CompositeMetadata).io.rsocket.kotlin.metadata/list(io.rsocket.kotlin.metadata/MetadataReader<#A>): kotlin.collections/List<#A> // io.rsocket.kotlin.metadata/list|list@io.rsocket.kotlin.metadata.CompositeMetadata(io.rsocket.kotlin.metadata.MetadataReader<0:0>){0§}[0] +final fun <#A: io.rsocket.kotlin.metadata/Metadata> (io.rsocket.kotlin.metadata/CompositeMetadata.Entry).io.rsocket.kotlin.metadata/read(io.rsocket.kotlin.metadata/MetadataReader<#A>): #A // io.rsocket.kotlin.metadata/read|read@io.rsocket.kotlin.metadata.CompositeMetadata.Entry(io.rsocket.kotlin.metadata.MetadataReader<0:0>){0§}[0] +final fun <#A: io.rsocket.kotlin.metadata/Metadata> (io.rsocket.kotlin.metadata/CompositeMetadata.Entry).io.rsocket.kotlin.metadata/readOrNull(io.rsocket.kotlin.metadata/MetadataReader<#A>): #A? // io.rsocket.kotlin.metadata/readOrNull|readOrNull@io.rsocket.kotlin.metadata.CompositeMetadata.Entry(io.rsocket.kotlin.metadata.MetadataReader<0:0>){0§}[0] +final fun <#A: io.rsocket.kotlin.metadata/Metadata> (kotlinx.io/Source).io.rsocket.kotlin.metadata/read(io.rsocket.kotlin.metadata/MetadataReader<#A>): #A // io.rsocket.kotlin.metadata/read|read@kotlinx.io.Source(io.rsocket.kotlin.metadata.MetadataReader<0:0>){0§}[0] +final fun io.rsocket.kotlin.core/RSocketConnector(kotlin/Function1 = ...): io.rsocket.kotlin.core/RSocketConnector // io.rsocket.kotlin.core/RSocketConnector|RSocketConnector(kotlin.Function1){}[0] +final fun io.rsocket.kotlin.core/RSocketServer(kotlin/Function1 = ...): io.rsocket.kotlin.core/RSocketServer // io.rsocket.kotlin.core/RSocketServer|RSocketServer(kotlin.Function1){}[0] +final fun io.rsocket.kotlin.keepalive/KeepAlive(kotlin.time/Duration = ..., kotlin.time/Duration = ...): io.rsocket.kotlin.keepalive/KeepAlive // io.rsocket.kotlin.keepalive/KeepAlive|KeepAlive(kotlin.time.Duration;kotlin.time.Duration){}[0] +final fun io.rsocket.kotlin.metadata/CompositeMetadata(kotlin.collections/List): io.rsocket.kotlin.metadata/CompositeMetadata // io.rsocket.kotlin.metadata/CompositeMetadata|CompositeMetadata(kotlin.collections.List){}[0] +final fun io.rsocket.kotlin.metadata/CompositeMetadata(kotlin/Array...): io.rsocket.kotlin.metadata/CompositeMetadata // io.rsocket.kotlin.metadata/CompositeMetadata|CompositeMetadata(kotlin.Array...){}[0] +final fun io.rsocket.kotlin.metadata/PerStreamAcceptableDataMimeTypesMetadata(kotlin/Array...): io.rsocket.kotlin.metadata/PerStreamAcceptableDataMimeTypesMetadata // io.rsocket.kotlin.metadata/PerStreamAcceptableDataMimeTypesMetadata|PerStreamAcceptableDataMimeTypesMetadata(kotlin.Array...){}[0] +final fun io.rsocket.kotlin.metadata/RoutingMetadata(kotlin/Array...): io.rsocket.kotlin.metadata/RoutingMetadata // io.rsocket.kotlin.metadata/RoutingMetadata|RoutingMetadata(kotlin.Array...){}[0] +final fun io.rsocket.kotlin.metadata/ZipkinTracingMetadata(io.rsocket.kotlin.metadata/ZipkinTracingMetadata.Kind): io.rsocket.kotlin.metadata/ZipkinTracingMetadata // io.rsocket.kotlin.metadata/ZipkinTracingMetadata|ZipkinTracingMetadata(io.rsocket.kotlin.metadata.ZipkinTracingMetadata.Kind){}[0] +final fun io.rsocket.kotlin.metadata/ZipkinTracingMetadata(io.rsocket.kotlin.metadata/ZipkinTracingMetadata.Kind, kotlin/Long, kotlin/Long): io.rsocket.kotlin.metadata/ZipkinTracingMetadata // io.rsocket.kotlin.metadata/ZipkinTracingMetadata|ZipkinTracingMetadata(io.rsocket.kotlin.metadata.ZipkinTracingMetadata.Kind;kotlin.Long;kotlin.Long){}[0] +final fun io.rsocket.kotlin.metadata/ZipkinTracingMetadata(io.rsocket.kotlin.metadata/ZipkinTracingMetadata.Kind, kotlin/Long, kotlin/Long, kotlin/Long): io.rsocket.kotlin.metadata/ZipkinTracingMetadata // io.rsocket.kotlin.metadata/ZipkinTracingMetadata|ZipkinTracingMetadata(io.rsocket.kotlin.metadata.ZipkinTracingMetadata.Kind;kotlin.Long;kotlin.Long;kotlin.Long){}[0] +final fun io.rsocket.kotlin.metadata/ZipkinTracingMetadata128(io.rsocket.kotlin.metadata/ZipkinTracingMetadata.Kind, kotlin/Long, kotlin/Long, kotlin/Long): io.rsocket.kotlin.metadata/ZipkinTracingMetadata // io.rsocket.kotlin.metadata/ZipkinTracingMetadata128|ZipkinTracingMetadata128(io.rsocket.kotlin.metadata.ZipkinTracingMetadata.Kind;kotlin.Long;kotlin.Long;kotlin.Long){}[0] +final fun io.rsocket.kotlin.metadata/ZipkinTracingMetadata128(io.rsocket.kotlin.metadata/ZipkinTracingMetadata.Kind, kotlin/Long, kotlin/Long, kotlin/Long, kotlin/Long): io.rsocket.kotlin.metadata/ZipkinTracingMetadata // io.rsocket.kotlin.metadata/ZipkinTracingMetadata128|ZipkinTracingMetadata128(io.rsocket.kotlin.metadata.ZipkinTracingMetadata.Kind;kotlin.Long;kotlin.Long;kotlin.Long;kotlin.Long){}[0] +final fun io.rsocket.kotlin.payload/Payload(kotlinx.io/Buffer, kotlinx.io/Buffer? = ...): io.rsocket.kotlin.payload/Payload // io.rsocket.kotlin.payload/Payload|Payload(kotlinx.io.Buffer;kotlinx.io.Buffer?){}[0] +final fun io.rsocket.kotlin.payload/PayloadMimeType(io.rsocket.kotlin.core/MimeTypeWithName, io.rsocket.kotlin.core/MimeTypeWithName): io.rsocket.kotlin.payload/PayloadMimeType // io.rsocket.kotlin.payload/PayloadMimeType|PayloadMimeType(io.rsocket.kotlin.core.MimeTypeWithName;io.rsocket.kotlin.core.MimeTypeWithName){}[0] +final fun io.rsocket.kotlin.transport/ClientTransport(kotlin.coroutines/CoroutineContext, io.rsocket.kotlin.transport/ClientTransport): io.rsocket.kotlin.transport/ClientTransport // io.rsocket.kotlin.transport/ClientTransport|ClientTransport(kotlin.coroutines.CoroutineContext;io.rsocket.kotlin.transport.ClientTransport){}[0] +final fun io.rsocket.kotlin/RSocketRequestHandler(kotlin.coroutines/CoroutineContext = ..., kotlin/Function1): io.rsocket.kotlin/RSocket // io.rsocket.kotlin/RSocketRequestHandler|RSocketRequestHandler(kotlin.coroutines.CoroutineContext;kotlin.Function1){}[0] +final inline fun (io.rsocket.kotlin.logging/Logger).io.rsocket.kotlin.logging/debug(kotlin/Throwable? = ..., kotlin/Function0) // io.rsocket.kotlin.logging/debug|debug@io.rsocket.kotlin.logging.Logger(kotlin.Throwable?;kotlin.Function0){}[0] +final inline fun (io.rsocket.kotlin.logging/Logger).io.rsocket.kotlin.logging/error(kotlin/Throwable? = ..., kotlin/Function0) // io.rsocket.kotlin.logging/error|error@io.rsocket.kotlin.logging.Logger(kotlin.Throwable?;kotlin.Function0){}[0] +final inline fun (io.rsocket.kotlin.logging/Logger).io.rsocket.kotlin.logging/info(kotlin/Throwable? = ..., kotlin/Function0) // io.rsocket.kotlin.logging/info|info@io.rsocket.kotlin.logging.Logger(kotlin.Throwable?;kotlin.Function0){}[0] +final inline fun (io.rsocket.kotlin.logging/Logger).io.rsocket.kotlin.logging/log(io.rsocket.kotlin.logging/LoggingLevel, kotlin/Throwable? = ..., kotlin/Function0) // io.rsocket.kotlin.logging/log|log@io.rsocket.kotlin.logging.Logger(io.rsocket.kotlin.logging.LoggingLevel;kotlin.Throwable?;kotlin.Function0){}[0] +final inline fun (io.rsocket.kotlin.logging/Logger).io.rsocket.kotlin.logging/trace(kotlin/Throwable? = ..., kotlin/Function0) // io.rsocket.kotlin.logging/trace|trace@io.rsocket.kotlin.logging.Logger(kotlin.Throwable?;kotlin.Function0){}[0] +final inline fun (io.rsocket.kotlin.logging/Logger).io.rsocket.kotlin.logging/warn(kotlin/Throwable? = ..., kotlin/Function0) // io.rsocket.kotlin.logging/warn|warn@io.rsocket.kotlin.logging.Logger(kotlin.Throwable?;kotlin.Function0){}[0] +final inline fun (io.rsocket.kotlin.payload/PayloadBuilder).io.rsocket.kotlin.metadata/compositeMetadata(kotlin/Function1) // io.rsocket.kotlin.metadata/compositeMetadata|compositeMetadata@io.rsocket.kotlin.payload.PayloadBuilder(kotlin.Function1){}[0] +final inline fun (io.rsocket.kotlin.payload/PayloadBuilder).io.rsocket.kotlin.payload/data(kotlin/Function1) // io.rsocket.kotlin.payload/data|data@io.rsocket.kotlin.payload.PayloadBuilder(kotlin.Function1){}[0] +final inline fun (io.rsocket.kotlin.payload/PayloadBuilder).io.rsocket.kotlin.payload/metadata(kotlin/Function1) // io.rsocket.kotlin.payload/metadata|metadata@io.rsocket.kotlin.payload.PayloadBuilder(kotlin.Function1){}[0] +final inline fun io.rsocket.kotlin.metadata/buildCompositeMetadata(kotlin/Function1): io.rsocket.kotlin.metadata/CompositeMetadata // io.rsocket.kotlin.metadata/buildCompositeMetadata|buildCompositeMetadata(kotlin.Function1){}[0] +final inline fun io.rsocket.kotlin.payload/buildPayload(kotlin/Function1): io.rsocket.kotlin.payload/Payload // io.rsocket.kotlin.payload/buildPayload|buildPayload(kotlin.Function1){}[0] +final suspend fun <#A: kotlin/AutoCloseable> (kotlinx.coroutines.flow/FlowCollector<#A>).io.rsocket.kotlin/emitOrClose(#A) // io.rsocket.kotlin/emitOrClose|emitOrClose@kotlinx.coroutines.flow.FlowCollector<0:0>(0:0){0§}[0] diff --git a/rsocket-internal-io/api/rsocket-internal-io.klib.api b/rsocket-internal-io/api/rsocket-internal-io.klib.api new file mode 100644 index 000000000..61987e4eb --- /dev/null +++ b/rsocket-internal-io/api/rsocket-internal-io.klib.api @@ -0,0 +1,20 @@ +// Klib ABI Dump +// Targets: [androidNativeArm32, androidNativeArm64, androidNativeX64, androidNativeX86, iosArm64, iosSimulatorArm64, iosX64, js, linuxArm64, linuxX64, macosArm64, macosX64, mingwX64, tvosArm64, tvosSimulatorArm64, tvosX64, wasmJs, wasmWasi, watchosArm32, watchosArm64, watchosDeviceArm64, watchosSimulatorArm64, watchosX64] +// Rendering settings: +// - Signature version: 2 +// - Show manifest properties: true +// - Show declarations: true + +// Library unique name: +final val io.rsocket.kotlin.internal.io/IoCompatible // io.rsocket.kotlin.internal.io/IoCompatible|@kotlinx.coroutines.Dispatchers{}IoCompatible[0] + final fun (kotlinx.coroutines/Dispatchers).(): kotlinx.coroutines/CoroutineDispatcher // io.rsocket.kotlin.internal.io/IoCompatible.|@kotlinx.coroutines.Dispatchers(){}[0] + +final fun (kotlin.coroutines/CoroutineContext).io.rsocket.kotlin.internal.io/childContext(): kotlin.coroutines/CoroutineContext // io.rsocket.kotlin.internal.io/childContext|childContext@kotlin.coroutines.CoroutineContext(){}[0] +final fun (kotlin.coroutines/CoroutineContext).io.rsocket.kotlin.internal.io/supervisorContext(): kotlin.coroutines/CoroutineContext // io.rsocket.kotlin.internal.io/supervisorContext|supervisorContext@kotlin.coroutines.CoroutineContext(){}[0] +final fun (kotlinx.coroutines.channels/Channel).io.rsocket.kotlin.internal.io/cancelWithCause(kotlin/Throwable?) // io.rsocket.kotlin.internal.io/cancelWithCause|cancelWithCause@kotlinx.coroutines.channels.Channel(kotlin.Throwable?){}[0] +final fun (kotlinx.io/Sink).io.rsocket.kotlin.internal.io/writeInt24(kotlin/Int) // io.rsocket.kotlin.internal.io/writeInt24|writeInt24@kotlinx.io.Sink(kotlin.Int){}[0] +final fun (kotlinx.io/Source).io.rsocket.kotlin.internal.io/readInt24(): kotlin/Int // io.rsocket.kotlin.internal.io/readInt24|readInt24@kotlinx.io.Source(){}[0] +final fun <#A: kotlin/AutoCloseable> io.rsocket.kotlin.internal.io/channelForCloseable(kotlin/Int): kotlinx.coroutines.channels/Channel<#A> // io.rsocket.kotlin.internal.io/channelForCloseable|channelForCloseable(kotlin.Int){0§}[0] +final fun <#A: kotlinx.coroutines/Job> (#A).io.rsocket.kotlin.internal.io/onCompletion(kotlin/Function1): #A // io.rsocket.kotlin.internal.io/onCompletion|onCompletion@0:0(kotlin.Function1){0§}[0] +final fun io.rsocket.kotlin.internal.io/bufferChannel(kotlin/Int): kotlinx.coroutines.channels/Channel // io.rsocket.kotlin.internal.io/bufferChannel|bufferChannel(kotlin.Int){}[0] +final suspend fun <#A: kotlin/Any?> io.rsocket.kotlin.internal.io/nonCancellable(kotlin.coroutines/SuspendFunction1): #A // io.rsocket.kotlin.internal.io/nonCancellable|nonCancellable(kotlin.coroutines.SuspendFunction1){0§}[0] diff --git a/rsocket-transports/ktor-tcp/api/rsocket-transport-ktor-tcp.klib.api b/rsocket-transports/ktor-tcp/api/rsocket-transport-ktor-tcp.klib.api new file mode 100644 index 000000000..26c35153c --- /dev/null +++ b/rsocket-transports/ktor-tcp/api/rsocket-transport-ktor-tcp.klib.api @@ -0,0 +1,48 @@ +// Klib ABI Dump +// Targets: [androidNativeArm32, androidNativeArm64, androidNativeX64, androidNativeX86, iosArm64, iosSimulatorArm64, iosX64, js, linuxArm64, linuxX64, macosArm64, macosX64, mingwX64, tvosArm64, tvosSimulatorArm64, tvosX64, wasmJs, watchosArm32, watchosArm64, watchosDeviceArm64, watchosSimulatorArm64, watchosX64] +// Rendering settings: +// - Signature version: 2 +// - Show manifest properties: true +// - Show declarations: true + +// Library unique name: +sealed interface io.rsocket.kotlin.transport.ktor.tcp/KtorTcpClientTransport : io.rsocket.kotlin.transport/RSocketTransport { // io.rsocket.kotlin.transport.ktor.tcp/KtorTcpClientTransport|null[0] + abstract fun target(io.ktor.network.sockets/SocketAddress): io.rsocket.kotlin.transport/RSocketClientTarget // io.rsocket.kotlin.transport.ktor.tcp/KtorTcpClientTransport.target|target(io.ktor.network.sockets.SocketAddress){}[0] + abstract fun target(kotlin/String, kotlin/Int): io.rsocket.kotlin.transport/RSocketClientTarget // io.rsocket.kotlin.transport.ktor.tcp/KtorTcpClientTransport.target|target(kotlin.String;kotlin.Int){}[0] + + final object Factory : io.rsocket.kotlin.transport/RSocketTransportFactory // io.rsocket.kotlin.transport.ktor.tcp/KtorTcpClientTransport.Factory|null[0] +} + +sealed interface io.rsocket.kotlin.transport.ktor.tcp/KtorTcpClientTransportBuilder : io.rsocket.kotlin.transport/RSocketTransportBuilder { // io.rsocket.kotlin.transport.ktor.tcp/KtorTcpClientTransportBuilder|null[0] + abstract fun selectorManager(io.ktor.network.selector/SelectorManager, kotlin/Boolean) // io.rsocket.kotlin.transport.ktor.tcp/KtorTcpClientTransportBuilder.selectorManager|selectorManager(io.ktor.network.selector.SelectorManager;kotlin.Boolean){}[0] + abstract fun socketOptions(kotlin/Function1) // io.rsocket.kotlin.transport.ktor.tcp/KtorTcpClientTransportBuilder.socketOptions|socketOptions(kotlin.Function1){}[0] +} + +sealed interface io.rsocket.kotlin.transport.ktor.tcp/KtorTcpServerInstance : io.rsocket.kotlin.transport/RSocketServerInstance { // io.rsocket.kotlin.transport.ktor.tcp/KtorTcpServerInstance|null[0] + abstract val localAddress // io.rsocket.kotlin.transport.ktor.tcp/KtorTcpServerInstance.localAddress|{}localAddress[0] + abstract fun (): io.ktor.network.sockets/SocketAddress // io.rsocket.kotlin.transport.ktor.tcp/KtorTcpServerInstance.localAddress.|(){}[0] +} + +sealed interface io.rsocket.kotlin.transport.ktor.tcp/KtorTcpServerTransport : io.rsocket.kotlin.transport/RSocketTransport { // io.rsocket.kotlin.transport.ktor.tcp/KtorTcpServerTransport|null[0] + abstract fun target(io.ktor.network.sockets/SocketAddress? = ...): io.rsocket.kotlin.transport/RSocketServerTarget // io.rsocket.kotlin.transport.ktor.tcp/KtorTcpServerTransport.target|target(io.ktor.network.sockets.SocketAddress?){}[0] + abstract fun target(kotlin/String = ..., kotlin/Int = ...): io.rsocket.kotlin.transport/RSocketServerTarget // io.rsocket.kotlin.transport.ktor.tcp/KtorTcpServerTransport.target|target(kotlin.String;kotlin.Int){}[0] + + final object Factory : io.rsocket.kotlin.transport/RSocketTransportFactory // io.rsocket.kotlin.transport.ktor.tcp/KtorTcpServerTransport.Factory|null[0] +} + +sealed interface io.rsocket.kotlin.transport.ktor.tcp/KtorTcpServerTransportBuilder : io.rsocket.kotlin.transport/RSocketTransportBuilder { // io.rsocket.kotlin.transport.ktor.tcp/KtorTcpServerTransportBuilder|null[0] + abstract fun selectorManager(io.ktor.network.selector/SelectorManager, kotlin/Boolean) // io.rsocket.kotlin.transport.ktor.tcp/KtorTcpServerTransportBuilder.selectorManager|selectorManager(io.ktor.network.selector.SelectorManager;kotlin.Boolean){}[0] + abstract fun socketOptions(kotlin/Function1) // io.rsocket.kotlin.transport.ktor.tcp/KtorTcpServerTransportBuilder.socketOptions|socketOptions(kotlin.Function1){}[0] +} + +final class io.rsocket.kotlin.transport.ktor.tcp/TcpServer { // io.rsocket.kotlin.transport.ktor.tcp/TcpServer|null[0] + final val handlerJob // io.rsocket.kotlin.transport.ktor.tcp/TcpServer.handlerJob|{}handlerJob[0] + final fun (): kotlinx.coroutines/Job // io.rsocket.kotlin.transport.ktor.tcp/TcpServer.handlerJob.|(){}[0] + final val serverSocket // io.rsocket.kotlin.transport.ktor.tcp/TcpServer.serverSocket|{}serverSocket[0] + final fun (): kotlinx.coroutines/Deferred // io.rsocket.kotlin.transport.ktor.tcp/TcpServer.serverSocket.|(){}[0] +} + +final fun io.rsocket.kotlin.transport.ktor.tcp/TcpClientTransport(io.ktor.network.sockets/InetSocketAddress, kotlin.coroutines/CoroutineContext = ..., kotlin/Function1 = ..., kotlin/Function1 = ...): io.rsocket.kotlin.transport/ClientTransport // io.rsocket.kotlin.transport.ktor.tcp/TcpClientTransport|TcpClientTransport(io.ktor.network.sockets.InetSocketAddress;kotlin.coroutines.CoroutineContext;kotlin.Function1;kotlin.Function1){}[0] +final fun io.rsocket.kotlin.transport.ktor.tcp/TcpClientTransport(kotlin/String, kotlin/Int, kotlin.coroutines/CoroutineContext = ..., kotlin/Function1 = ..., kotlin/Function1 = ...): io.rsocket.kotlin.transport/ClientTransport // io.rsocket.kotlin.transport.ktor.tcp/TcpClientTransport|TcpClientTransport(kotlin.String;kotlin.Int;kotlin.coroutines.CoroutineContext;kotlin.Function1;kotlin.Function1){}[0] +final fun io.rsocket.kotlin.transport.ktor.tcp/TcpServerTransport(io.ktor.network.sockets/InetSocketAddress? = ..., kotlin/Function1 = ...): io.rsocket.kotlin.transport/ServerTransport // io.rsocket.kotlin.transport.ktor.tcp/TcpServerTransport|TcpServerTransport(io.ktor.network.sockets.InetSocketAddress?;kotlin.Function1){}[0] +final fun io.rsocket.kotlin.transport.ktor.tcp/TcpServerTransport(kotlin/String = ..., kotlin/Int = ..., kotlin/Function1 = ...): io.rsocket.kotlin.transport/ServerTransport // io.rsocket.kotlin.transport.ktor.tcp/TcpServerTransport|TcpServerTransport(kotlin.String;kotlin.Int;kotlin.Function1){}[0] diff --git a/rsocket-transports/ktor-websocket-client/api/rsocket-transport-ktor-websocket-client.klib.api b/rsocket-transports/ktor-websocket-client/api/rsocket-transport-ktor-websocket-client.klib.api new file mode 100644 index 000000000..e17a816f7 --- /dev/null +++ b/rsocket-transports/ktor-websocket-client/api/rsocket-transport-ktor-websocket-client.klib.api @@ -0,0 +1,26 @@ +// Klib ABI Dump +// Targets: [androidNativeArm32, androidNativeArm64, androidNativeX64, androidNativeX86, iosArm64, iosSimulatorArm64, iosX64, js, linuxArm64, linuxX64, macosArm64, macosX64, mingwX64, tvosArm64, tvosSimulatorArm64, tvosX64, wasmJs, watchosArm32, watchosArm64, watchosDeviceArm64, watchosSimulatorArm64, watchosX64] +// Rendering settings: +// - Signature version: 2 +// - Show manifest properties: true +// - Show declarations: true + +// Library unique name: +sealed interface io.rsocket.kotlin.transport.ktor.websocket.client/KtorWebSocketClientTransport : io.rsocket.kotlin.transport/RSocketTransport { // io.rsocket.kotlin.transport.ktor.websocket.client/KtorWebSocketClientTransport|null[0] + abstract fun target(io.ktor.http/HttpMethod = ..., kotlin/String? = ..., kotlin/Int? = ..., kotlin/String? = ..., kotlin/Function1 = ...): io.rsocket.kotlin.transport/RSocketClientTarget // io.rsocket.kotlin.transport.ktor.websocket.client/KtorWebSocketClientTransport.target|target(io.ktor.http.HttpMethod;kotlin.String?;kotlin.Int?;kotlin.String?;kotlin.Function1){}[0] + abstract fun target(kotlin/Function1): io.rsocket.kotlin.transport/RSocketClientTarget // io.rsocket.kotlin.transport.ktor.websocket.client/KtorWebSocketClientTransport.target|target(kotlin.Function1){}[0] + abstract fun target(kotlin/String, kotlin/Function1 = ...): io.rsocket.kotlin.transport/RSocketClientTarget // io.rsocket.kotlin.transport.ktor.websocket.client/KtorWebSocketClientTransport.target|target(kotlin.String;kotlin.Function1){}[0] + + final object Factory : io.rsocket.kotlin.transport/RSocketTransportFactory // io.rsocket.kotlin.transport.ktor.websocket.client/KtorWebSocketClientTransport.Factory|null[0] +} + +sealed interface io.rsocket.kotlin.transport.ktor.websocket.client/KtorWebSocketClientTransportBuilder : io.rsocket.kotlin.transport/RSocketTransportBuilder { // io.rsocket.kotlin.transport.ktor.websocket.client/KtorWebSocketClientTransportBuilder|null[0] + abstract fun <#A1: io.ktor.client.engine/HttpClientEngineConfig> httpEngine(io.ktor.client.engine/HttpClientEngineFactory<#A1>, kotlin/Function1<#A1, kotlin/Unit> = ...) // io.rsocket.kotlin.transport.ktor.websocket.client/KtorWebSocketClientTransportBuilder.httpEngine|httpEngine(io.ktor.client.engine.HttpClientEngineFactory<0:0>;kotlin.Function1<0:0,kotlin.Unit>){0§}[0] + abstract fun httpEngine(io.ktor.client.engine/HttpClientEngine, kotlin/Function1 = ...) // io.rsocket.kotlin.transport.ktor.websocket.client/KtorWebSocketClientTransportBuilder.httpEngine|httpEngine(io.ktor.client.engine.HttpClientEngine;kotlin.Function1){}[0] + abstract fun httpEngine(kotlin/Function1) // io.rsocket.kotlin.transport.ktor.websocket.client/KtorWebSocketClientTransportBuilder.httpEngine|httpEngine(kotlin.Function1){}[0] + abstract fun webSocketsConfig(kotlin/Function1) // io.rsocket.kotlin.transport.ktor.websocket.client/KtorWebSocketClientTransportBuilder.webSocketsConfig|webSocketsConfig(kotlin.Function1){}[0] +} + +final fun <#A: io.ktor.client.engine/HttpClientEngineConfig> io.rsocket.kotlin.transport.ktor.websocket.client/WebSocketClientTransport(io.ktor.client.engine/HttpClientEngineFactory<#A>, kotlin.coroutines/CoroutineContext = ..., kotlin/Function1<#A, kotlin/Unit> = ..., kotlin/Function1 = ..., kotlin/Function1): io.rsocket.kotlin.transport/ClientTransport // io.rsocket.kotlin.transport.ktor.websocket.client/WebSocketClientTransport|WebSocketClientTransport(io.ktor.client.engine.HttpClientEngineFactory<0:0>;kotlin.coroutines.CoroutineContext;kotlin.Function1<0:0,kotlin.Unit>;kotlin.Function1;kotlin.Function1){0§}[0] +final fun <#A: io.ktor.client.engine/HttpClientEngineConfig> io.rsocket.kotlin.transport.ktor.websocket.client/WebSocketClientTransport(io.ktor.client.engine/HttpClientEngineFactory<#A>, kotlin/String, kotlin/Boolean = ..., kotlin.coroutines/CoroutineContext = ..., kotlin/Function1 = ..., kotlin/Function1 = ..., kotlin/Function1 = ...): io.rsocket.kotlin.transport/ClientTransport // io.rsocket.kotlin.transport.ktor.websocket.client/WebSocketClientTransport|WebSocketClientTransport(io.ktor.client.engine.HttpClientEngineFactory<0:0>;kotlin.String;kotlin.Boolean;kotlin.coroutines.CoroutineContext;kotlin.Function1;kotlin.Function1;kotlin.Function1){0§}[0] +final fun <#A: io.ktor.client.engine/HttpClientEngineConfig> io.rsocket.kotlin.transport.ktor.websocket.client/WebSocketClientTransport(io.ktor.client.engine/HttpClientEngineFactory<#A>, kotlin/String? = ..., kotlin/Int? = ..., kotlin/String? = ..., kotlin/Boolean = ..., kotlin.coroutines/CoroutineContext = ..., kotlin/Function1 = ..., kotlin/Function1 = ..., kotlin/Function1 = ...): io.rsocket.kotlin.transport/ClientTransport // io.rsocket.kotlin.transport.ktor.websocket.client/WebSocketClientTransport|WebSocketClientTransport(io.ktor.client.engine.HttpClientEngineFactory<0:0>;kotlin.String?;kotlin.Int?;kotlin.String?;kotlin.Boolean;kotlin.coroutines.CoroutineContext;kotlin.Function1;kotlin.Function1;kotlin.Function1){0§}[0] diff --git a/rsocket-transports/ktor-websocket-internal/api/rsocket-transport-ktor-websocket-internal.klib.api b/rsocket-transports/ktor-websocket-internal/api/rsocket-transport-ktor-websocket-internal.klib.api new file mode 100644 index 000000000..37764fef0 --- /dev/null +++ b/rsocket-transports/ktor-websocket-internal/api/rsocket-transport-ktor-websocket-internal.klib.api @@ -0,0 +1,27 @@ +// Klib ABI Dump +// Targets: [androidNativeArm32, androidNativeArm64, androidNativeX64, androidNativeX86, iosArm64, iosSimulatorArm64, iosX64, js, linuxArm64, linuxX64, macosArm64, macosX64, mingwX64, tvosArm64, tvosSimulatorArm64, tvosX64, wasmJs, watchosArm32, watchosArm64, watchosDeviceArm64, watchosSimulatorArm64, watchosX64] +// Rendering settings: +// - Signature version: 2 +// - Show manifest properties: true +// - Show declarations: true + +// Library unique name: +final class io.rsocket.kotlin.transport.ktor.websocket.internal/KtorWebSocketConnection : io.rsocket.kotlin.transport/RSocketSequentialConnection { // io.rsocket.kotlin.transport.ktor.websocket.internal/KtorWebSocketConnection|null[0] + constructor (io.ktor.websocket/WebSocketSession) // io.rsocket.kotlin.transport.ktor.websocket.internal/KtorWebSocketConnection.|(io.ktor.websocket.WebSocketSession){}[0] + + final val coroutineContext // io.rsocket.kotlin.transport.ktor.websocket.internal/KtorWebSocketConnection.coroutineContext|{}coroutineContext[0] + final fun (): kotlin.coroutines/CoroutineContext // io.rsocket.kotlin.transport.ktor.websocket.internal/KtorWebSocketConnection.coroutineContext.|(){}[0] + + final suspend fun receiveFrame(): kotlinx.io/Buffer? // io.rsocket.kotlin.transport.ktor.websocket.internal/KtorWebSocketConnection.receiveFrame|receiveFrame(){}[0] + final suspend fun sendFrame(kotlin/Int, kotlinx.io/Buffer) // io.rsocket.kotlin.transport.ktor.websocket.internal/KtorWebSocketConnection.sendFrame|sendFrame(kotlin.Int;kotlinx.io.Buffer){}[0] +} + +final class io.rsocket.kotlin.transport.ktor.websocket.internal/WebSocketConnection : io.rsocket.kotlin/Connection, kotlinx.coroutines/CoroutineScope { // io.rsocket.kotlin.transport.ktor.websocket.internal/WebSocketConnection|null[0] + constructor (io.ktor.websocket/WebSocketSession) // io.rsocket.kotlin.transport.ktor.websocket.internal/WebSocketConnection.|(io.ktor.websocket.WebSocketSession){}[0] + + final val coroutineContext // io.rsocket.kotlin.transport.ktor.websocket.internal/WebSocketConnection.coroutineContext|{}coroutineContext[0] + final fun (): kotlin.coroutines/CoroutineContext // io.rsocket.kotlin.transport.ktor.websocket.internal/WebSocketConnection.coroutineContext.|(){}[0] + + final suspend fun receive(): kotlinx.io/Buffer // io.rsocket.kotlin.transport.ktor.websocket.internal/WebSocketConnection.receive|receive(){}[0] + final suspend fun send(kotlinx.io/Buffer) // io.rsocket.kotlin.transport.ktor.websocket.internal/WebSocketConnection.send|send(kotlinx.io.Buffer){}[0] +} diff --git a/rsocket-transports/ktor-websocket-server/api/rsocket-transport-ktor-websocket-server.klib.api b/rsocket-transports/ktor-websocket-server/api/rsocket-transport-ktor-websocket-server.klib.api new file mode 100644 index 000000000..2758fab6e --- /dev/null +++ b/rsocket-transports/ktor-websocket-server/api/rsocket-transport-ktor-websocket-server.klib.api @@ -0,0 +1,33 @@ +// Klib ABI Dump +// Targets: [androidNativeArm32, androidNativeArm64, androidNativeX64, androidNativeX86, iosArm64, iosSimulatorArm64, iosX64, js, linuxArm64, linuxX64, macosArm64, macosX64, mingwX64, tvosArm64, tvosSimulatorArm64, tvosX64, wasmJs, watchosArm32, watchosArm64, watchosDeviceArm64, watchosSimulatorArm64, watchosX64] +// Rendering settings: +// - Signature version: 2 +// - Show manifest properties: true +// - Show declarations: true + +// Library unique name: +sealed interface io.rsocket.kotlin.transport.ktor.websocket.server/KtorWebSocketServerInstance : io.rsocket.kotlin.transport/RSocketServerInstance { // io.rsocket.kotlin.transport.ktor.websocket.server/KtorWebSocketServerInstance|null[0] + abstract val connectors // io.rsocket.kotlin.transport.ktor.websocket.server/KtorWebSocketServerInstance.connectors|{}connectors[0] + abstract fun (): kotlin.collections/List // io.rsocket.kotlin.transport.ktor.websocket.server/KtorWebSocketServerInstance.connectors.|(){}[0] + abstract val path // io.rsocket.kotlin.transport.ktor.websocket.server/KtorWebSocketServerInstance.path|{}path[0] + abstract fun (): kotlin/String // io.rsocket.kotlin.transport.ktor.websocket.server/KtorWebSocketServerInstance.path.|(){}[0] + abstract val protocol // io.rsocket.kotlin.transport.ktor.websocket.server/KtorWebSocketServerInstance.protocol|{}protocol[0] + abstract fun (): kotlin/String? // io.rsocket.kotlin.transport.ktor.websocket.server/KtorWebSocketServerInstance.protocol.|(){}[0] +} + +sealed interface io.rsocket.kotlin.transport.ktor.websocket.server/KtorWebSocketServerTransport : io.rsocket.kotlin.transport/RSocketTransport { // io.rsocket.kotlin.transport.ktor.websocket.server/KtorWebSocketServerTransport|null[0] + abstract fun target(io.ktor.server.engine/EngineConnectorConfig, kotlin/String = ..., kotlin/String? = ...): io.rsocket.kotlin.transport/RSocketServerTarget // io.rsocket.kotlin.transport.ktor.websocket.server/KtorWebSocketServerTransport.target|target(io.ktor.server.engine.EngineConnectorConfig;kotlin.String;kotlin.String?){}[0] + abstract fun target(kotlin.collections/List, kotlin/String = ..., kotlin/String? = ...): io.rsocket.kotlin.transport/RSocketServerTarget // io.rsocket.kotlin.transport.ktor.websocket.server/KtorWebSocketServerTransport.target|target(kotlin.collections.List;kotlin.String;kotlin.String?){}[0] + abstract fun target(kotlin/String = ..., kotlin/Int = ..., kotlin/String = ..., kotlin/String? = ...): io.rsocket.kotlin.transport/RSocketServerTarget // io.rsocket.kotlin.transport.ktor.websocket.server/KtorWebSocketServerTransport.target|target(kotlin.String;kotlin.Int;kotlin.String;kotlin.String?){}[0] + abstract fun target(kotlin/String = ..., kotlin/String? = ..., kotlin/Function1): io.rsocket.kotlin.transport/RSocketServerTarget // io.rsocket.kotlin.transport.ktor.websocket.server/KtorWebSocketServerTransport.target|target(kotlin.String;kotlin.String?;kotlin.Function1){}[0] + + final object Factory : io.rsocket.kotlin.transport/RSocketTransportFactory // io.rsocket.kotlin.transport.ktor.websocket.server/KtorWebSocketServerTransport.Factory|null[0] +} + +sealed interface io.rsocket.kotlin.transport.ktor.websocket.server/KtorWebSocketServerTransportBuilder : io.rsocket.kotlin.transport/RSocketTransportBuilder { // io.rsocket.kotlin.transport.ktor.websocket.server/KtorWebSocketServerTransportBuilder|null[0] + abstract fun <#A1: io.ktor.server.engine/ApplicationEngine, #B1: io.ktor.server.engine/ApplicationEngine.Configuration> httpEngine(io.ktor.server.engine/ApplicationEngineFactory<#A1, #B1>, kotlin/Function1<#B1, kotlin/Unit> = ...) // io.rsocket.kotlin.transport.ktor.websocket.server/KtorWebSocketServerTransportBuilder.httpEngine|httpEngine(io.ktor.server.engine.ApplicationEngineFactory<0:0,0:1>;kotlin.Function1<0:1,kotlin.Unit>){0§;1§}[0] + abstract fun webSocketsConfig(kotlin/Function1) // io.rsocket.kotlin.transport.ktor.websocket.server/KtorWebSocketServerTransportBuilder.webSocketsConfig|webSocketsConfig(kotlin.Function1){}[0] +} + +final fun <#A: io.ktor.server.engine/ApplicationEngine, #B: io.ktor.server.engine/ApplicationEngine.Configuration> io.rsocket.kotlin.transport.ktor.websocket.server/WebSocketServerTransport(io.ktor.server.engine/ApplicationEngineFactory<#A, #B>, kotlin/Array..., kotlin/String? = ..., kotlin/String? = ..., kotlin/Function1<#B, kotlin/Unit> = ..., kotlin/Function1 = ...): io.rsocket.kotlin.transport/ServerTransport> // io.rsocket.kotlin.transport.ktor.websocket.server/WebSocketServerTransport|WebSocketServerTransport(io.ktor.server.engine.ApplicationEngineFactory<0:0,0:1>;kotlin.Array...;kotlin.String?;kotlin.String?;kotlin.Function1<0:1,kotlin.Unit>;kotlin.Function1){0§;1§}[0] +final fun <#A: io.ktor.server.engine/ApplicationEngine, #B: io.ktor.server.engine/ApplicationEngine.Configuration> io.rsocket.kotlin.transport.ktor.websocket.server/WebSocketServerTransport(io.ktor.server.engine/ApplicationEngineFactory<#A, #B>, kotlin/Int = ..., kotlin/String = ..., kotlin/String? = ..., kotlin/String? = ..., kotlin/Function1<#B, kotlin/Unit> = ..., kotlin/Function1 = ...): io.rsocket.kotlin.transport/ServerTransport> // io.rsocket.kotlin.transport.ktor.websocket.server/WebSocketServerTransport|WebSocketServerTransport(io.ktor.server.engine.ApplicationEngineFactory<0:0,0:1>;kotlin.Int;kotlin.String;kotlin.String?;kotlin.String?;kotlin.Function1<0:1,kotlin.Unit>;kotlin.Function1){0§;1§}[0] diff --git a/rsocket-transports/local/api/rsocket-transport-local.klib.api b/rsocket-transports/local/api/rsocket-transport-local.klib.api new file mode 100644 index 000000000..6de216fe3 --- /dev/null +++ b/rsocket-transports/local/api/rsocket-transport-local.klib.api @@ -0,0 +1,44 @@ +// Klib ABI Dump +// Targets: [androidNativeArm32, androidNativeArm64, androidNativeX64, androidNativeX86, iosArm64, iosSimulatorArm64, iosX64, js, linuxArm64, linuxX64, macosArm64, macosX64, mingwX64, tvosArm64, tvosSimulatorArm64, tvosX64, wasmJs, wasmWasi, watchosArm32, watchosArm64, watchosDeviceArm64, watchosSimulatorArm64, watchosX64] +// Rendering settings: +// - Signature version: 2 +// - Show manifest properties: true +// - Show declarations: true + +// Library unique name: +sealed interface io.rsocket.kotlin.transport.local/LocalClientTransport : io.rsocket.kotlin.transport/RSocketTransport { // io.rsocket.kotlin.transport.local/LocalClientTransport|null[0] + abstract fun target(kotlin/String): io.rsocket.kotlin.transport/RSocketClientTarget // io.rsocket.kotlin.transport.local/LocalClientTransport.target|target(kotlin.String){}[0] + + final object Factory : io.rsocket.kotlin.transport/RSocketTransportFactory // io.rsocket.kotlin.transport.local/LocalClientTransport.Factory|null[0] +} + +sealed interface io.rsocket.kotlin.transport.local/LocalClientTransportBuilder : io.rsocket.kotlin.transport/RSocketTransportBuilder { // io.rsocket.kotlin.transport.local/LocalClientTransportBuilder|null[0] + abstract fun dispatcher(kotlin.coroutines/CoroutineContext) // io.rsocket.kotlin.transport.local/LocalClientTransportBuilder.dispatcher|dispatcher(kotlin.coroutines.CoroutineContext){}[0] +} + +sealed interface io.rsocket.kotlin.transport.local/LocalServerInstance : io.rsocket.kotlin.transport/RSocketServerInstance { // io.rsocket.kotlin.transport.local/LocalServerInstance|null[0] + abstract val serverName // io.rsocket.kotlin.transport.local/LocalServerInstance.serverName|{}serverName[0] + abstract fun (): kotlin/String // io.rsocket.kotlin.transport.local/LocalServerInstance.serverName.|(){}[0] +} + +sealed interface io.rsocket.kotlin.transport.local/LocalServerTransport : io.rsocket.kotlin.transport/RSocketTransport { // io.rsocket.kotlin.transport.local/LocalServerTransport|null[0] + abstract fun target(): io.rsocket.kotlin.transport/RSocketServerTarget // io.rsocket.kotlin.transport.local/LocalServerTransport.target|target(){}[0] + abstract fun target(kotlin/String): io.rsocket.kotlin.transport/RSocketServerTarget // io.rsocket.kotlin.transport.local/LocalServerTransport.target|target(kotlin.String){}[0] + + final object Factory : io.rsocket.kotlin.transport/RSocketTransportFactory // io.rsocket.kotlin.transport.local/LocalServerTransport.Factory|null[0] +} + +sealed interface io.rsocket.kotlin.transport.local/LocalServerTransportBuilder : io.rsocket.kotlin.transport/RSocketTransportBuilder { // io.rsocket.kotlin.transport.local/LocalServerTransportBuilder|null[0] + abstract fun dispatcher(kotlin.coroutines/CoroutineContext) // io.rsocket.kotlin.transport.local/LocalServerTransportBuilder.dispatcher|dispatcher(kotlin.coroutines.CoroutineContext){}[0] + abstract fun multiplexed() // io.rsocket.kotlin.transport.local/LocalServerTransportBuilder.multiplexed|multiplexed(){}[0] + abstract fun sequential() // io.rsocket.kotlin.transport.local/LocalServerTransportBuilder.sequential|sequential(){}[0] +} + +final class io.rsocket.kotlin.transport.local/LocalServer : io.rsocket.kotlin.transport/ClientTransport { // io.rsocket.kotlin.transport.local/LocalServer|null[0] + final val coroutineContext // io.rsocket.kotlin.transport.local/LocalServer.coroutineContext|{}coroutineContext[0] + final fun (): kotlin.coroutines/CoroutineContext // io.rsocket.kotlin.transport.local/LocalServer.coroutineContext.|(){}[0] + + final suspend fun connect(): io.rsocket.kotlin/Connection // io.rsocket.kotlin.transport.local/LocalServer.connect|connect(){}[0] +} + +final fun io.rsocket.kotlin.transport.local/LocalServerTransport(): io.rsocket.kotlin.transport/ServerTransport // io.rsocket.kotlin.transport.local/LocalServerTransport|LocalServerTransport(){}[0] diff --git a/rsocket-transports/netty-internal/api/rsocket-transport-netty-internal.klib.api b/rsocket-transports/netty-internal/api/rsocket-transport-netty-internal.klib.api new file mode 100644 index 000000000..e69de29bb diff --git a/rsocket-transports/netty-quic/api/rsocket-transport-netty-quic.klib.api b/rsocket-transports/netty-quic/api/rsocket-transport-netty-quic.klib.api new file mode 100644 index 000000000..e69de29bb diff --git a/rsocket-transports/netty-tcp/api/rsocket-transport-netty-tcp.klib.api b/rsocket-transports/netty-tcp/api/rsocket-transport-netty-tcp.klib.api new file mode 100644 index 000000000..e69de29bb diff --git a/rsocket-transports/nodejs-tcp/api/rsocket-transport-nodejs-tcp.klib.api b/rsocket-transports/nodejs-tcp/api/rsocket-transport-nodejs-tcp.klib.api new file mode 100644 index 000000000..ee51e97f4 --- /dev/null +++ b/rsocket-transports/nodejs-tcp/api/rsocket-transport-nodejs-tcp.klib.api @@ -0,0 +1,29 @@ +// Klib ABI Dump +// Targets: [js] +// Rendering settings: +// - Signature version: 2 +// - Show manifest properties: true +// - Show declarations: true + +// Library unique name: +final class io.rsocket.kotlin.transport.nodejs.tcp/TcpClientTransport : io.rsocket.kotlin.transport/ClientTransport { // io.rsocket.kotlin.transport.nodejs.tcp/TcpClientTransport|null[0] + constructor (kotlin/Int, kotlin/String, kotlin.coroutines/CoroutineContext = ...) // io.rsocket.kotlin.transport.nodejs.tcp/TcpClientTransport.|(kotlin.Int;kotlin.String;kotlin.coroutines.CoroutineContext){}[0] + + final val coroutineContext // io.rsocket.kotlin.transport.nodejs.tcp/TcpClientTransport.coroutineContext|{}coroutineContext[0] + final fun (): kotlin.coroutines/CoroutineContext // io.rsocket.kotlin.transport.nodejs.tcp/TcpClientTransport.coroutineContext.|(){}[0] + + final suspend fun connect(): io.rsocket.kotlin/Connection // io.rsocket.kotlin.transport.nodejs.tcp/TcpClientTransport.connect|connect(){}[0] +} + +final class io.rsocket.kotlin.transport.nodejs.tcp/TcpServer { // io.rsocket.kotlin.transport.nodejs.tcp/TcpServer|null[0] + final val job // io.rsocket.kotlin.transport.nodejs.tcp/TcpServer.job|{}job[0] + final fun (): kotlinx.coroutines/Job // io.rsocket.kotlin.transport.nodejs.tcp/TcpServer.job.|(){}[0] + + final suspend fun close() // io.rsocket.kotlin.transport.nodejs.tcp/TcpServer.close|close(){}[0] +} + +final class io.rsocket.kotlin.transport.nodejs.tcp/TcpServerTransport : io.rsocket.kotlin.transport/ServerTransport { // io.rsocket.kotlin.transport.nodejs.tcp/TcpServerTransport|null[0] + constructor (kotlin/Int, kotlin/String) // io.rsocket.kotlin.transport.nodejs.tcp/TcpServerTransport.|(kotlin.Int;kotlin.String){}[0] + + final fun (kotlinx.coroutines/CoroutineScope).start(kotlin.coroutines/SuspendFunction2): io.rsocket.kotlin.transport.nodejs.tcp/TcpServer // io.rsocket.kotlin.transport.nodejs.tcp/TcpServerTransport.start|start@kotlinx.coroutines.CoroutineScope(kotlin.coroutines.SuspendFunction2){}[0] +}