Attaches the opaque native connection handle produced by the native initialize export and starts the receive loop. Called once, after construction, because native initialization is asynchronous.

call

open suspend override fun call(channelId: ChannelId, endpoint: String, data: CallData<JniSerialized>, callId: RpcCallId?): CallData<JniSerialized>

cancelHandler

open override fun cancelHandler(callId: RpcCallId, cause: CancellationException?)

open suspend override fun close()

external fun close(nativeObject: Long, continuation: JavaJniContinuation<Int>)

open suspend override fun close(id: ChannelId)

closeFromNative

fun closeFromNative(continuation: NativeJniContinuation<Int>)

defaultChannel

open suspend override fun defaultChannel(): SerializedService<JniSerialized>

finalize

fun finalize()

external fun finalize(nativeObject: Long)

getNativeConnection

fun getNativeConnection(): Long

onClose

open suspend override fun onClose(onClose: suspend () -> Unit)

receive

suspend fun receive(): Packet<JniSerialized>

receiveLocked

open suspend override fun receiveLocked(): Packet<JniSerialized>

registerDefault

open suspend override fun registerDefault(service: SerializedService<JniSerialized>)

registerHandler

open override fun registerHandler(callId: RpcCallId, job: Job)

registerHost

open suspend override fun registerHost(service: SerializedService<JniSerialized>): ChannelId

send

suspend fun send(packet: Packet<JniSerialized>)

sendCancel

open suspend override fun sendCancel(callId: RpcCallId)

sendFromNative

fun sendFromNative(packet: JniSerialized, continuation: NativeJniContinuation<Int>)

sendLocked

open suspend override fun sendLocked(packet: Packet<JniSerialized>)

sendSerialized

external fun sendSerialized(nativeObject: Long, packet: JniSerialized, continuation: JavaJniContinuation<Int>)

unregisterHandler

open override fun unregisterHandler(callId: RpcCallId)

wrapChannel

open suspend override fun wrapChannel(channelId: ChannelId): SerializedService<JniSerialized>