kotlinx-rpc-krpc-test/kotlinx.rpc.krpc.test/KrpcTransportTestBase

KrpcTransportTestBase

abstract class KrpcTransportTestBase(source)

Constructors

KrpcTransportTestBase

constructor()

Types

class AtomicTest

Properties

clientTransport

abstract val clientTransport: KrpcTransport

serializationConfig

protected abstract val serializationConfig: KrpcSerialFormatConfiguration.() -> Unit

serializersModule

protected val serializersModule: SerializersModule

serverTransport

abstract val serverTransport: KrpcTransport

Functions

bidirectionalEchoStream

fun bidirectionalEchoStream(): TestResult

bidirectionalStream

fun bidirectionalStream(): TestResult

fun customType(): TestResult

doubleGenericParams

fun doubleGenericParams(): TestResult

doubleGenericReturnType

fun doubleGenericReturnType(): TestResult

fun genericParams(): TestResult

genericReturnType

fun genericReturnType(): TestResult

incomingStreamSyncCollect

fun incomingStreamSyncCollect(): TestResult

incomingStreamSyncCollectMultiple

fun incomingStreamSyncCollectMultiple(): TestResult

fun mapParams(): TestResult

nonSerializableParameter

fun nonSerializableParameter(): TestResult

fun nonSuspend(): TestResult

nonSuspendBidirectional

fun nonSuspendBidirectional(): TestResult

nonSuspendBidirectionalPayload

fun nonSuspendBidirectionalPayload(): TestResult

nonSuspendErrorOnEmit

fun nonSuspendErrorOnEmit(): TestResult

nonSuspendErrorOnReturn

fun nonSuspendErrorOnReturn(): TestResult

nullableNonSerializableParameter

open fun nullableNonSerializableParameter(): TestResult

nullableParameter

open fun nullableParameter(): TestResult

open fun nullableReturn(): TestResult

fun outgoingStream(): TestResult

fun paramsDouble(): TestResult

fun paramsSingle(): TestResult

fun returnType(): TestResult

rpc continuation is called in the correct scope and doesn't block other rpcs

fun rpc continuation is called in the correct scope and doesn't block other rpcs(): TestResult

RPC should be able to receive 100_000 ints in reasonable time

fun RPC should be able to receive 100_000 ints in reasonable time(): TestResult

RPC should be able to receive 100_000 ints with batching in reasonable time

fun RPC should be able to receive 100_000 ints with batching in reasonable time(): TestResult

simpleWithParams

fun simpleWithParams(): TestResult

simpleWithParams100000

fun simpleWithParams100000(): TestResult

fun start()

streamInDataClass

fun streamInDataClass(): TestResult

testByteArraySerialization

open fun testByteArraySerialization(): TestResult

testExceptionSerializationAndPropagating

fun testExceptionSerializationAndPropagating(): TestResult

fun testKrpc173(): TestResult

testNullableLists

open fun testNullableLists(): TestResult

open fun testNullables(): TestResult

testServerCallCancellation

fun testServerCallCancellation(): TestResult

fun testUnitFlow(): TestResult

fun varargParams(): TestResult

fun variance(): TestResult