test-utils-base/com.splendo.kaluga.test.base

Package-level declarations

Types

typealias ActionBlock = suspend () -> Unit

abstract class BaseFlowTest<Configration, Context : BaseUIThreadTest.TestContext, T, F : Flow<T>>(val scope: CoroutineScope = MainScope(), val logger: Logger? = null) : BaseUIThreadTest<Configration, Context> , CoroutineScope

BaseTest

actual open class BaseTest

expect open class BaseTest

actual open class BaseTest

BaseUIThreadTest

abstract class BaseUIThreadTest<Configuration, Context : BaseUIThreadTest.TestContext> : BaseTest

This class allows a test block to be run on the UI thread inside a custom context that is also created in the UI Thread using a configuration.

DeliberateCancellationException

class DeliberateCancellationException(val result: Any?) : CancellationException

FlowableTest

abstract class FlowableTest<T> : BaseTest

FlowTest

abstract class FlowTest<T, F : Flow<T>>(scope: CoroutineScope = MainScope()) : BaseFlowTest<Unit, BaseUIThreadTest.EmptyTestContext, T, F>

FlowTestBlock

typealias FlowTestBlock<T, F> = suspend FlowTest<T, F>.(F) -> Unit

FlowTestBlockWithContext

typealias FlowTestBlockWithContext<Configuration, Context, T, F> = suspend BaseFlowTest<Configuration, Context, T, F>.(F) -> Unit

ScopeActionBlock

typealias ScopeActionBlock<Context> = suspend Context.() -> Unit

SimpleFlowTest

abstract class SimpleFlowTest<T>(scope: CoroutineScope = MainScope()) : FlowTest<T, Flow<T>>

SimpleUIThreadTest

open class SimpleUIThreadTest : UIThreadTest<SimpleUIThreadTest.SimpleTestContext>

TestBlock

typealias TestBlock<Context, T> = suspend Context.(T) -> Unit

UIThreadTest

abstract class UIThreadTest<Context : UIThreadTest.TestContext> : BaseUIThreadTest<Unit, Context>

This class allows a test block to be run on the UI thread inside a custom context that is also created in the UI Thread.

Properties

DEFAULT_MULTIPLE_TIMES_YIELDS

const val DEFAULT_MULTIPLE_TIMES_YIELDS: Int = 10

Functions

assertEmits

suspend fun <T> Flow<T>.assertEmits(expected: T, message: String = "", timeout: Duration = defaultTimeout)

Asserts that the flow emits an element matching expected within timeout.

suspend fun <T> Flow<T>.assertEmits(message: String = "", timeout: Duration = defaultTimeout, condition: suspend (T) -> Boolean)

Asserts that the flow emits an element matching condition within timeout.

awaitAllBlocking

fun <T> awaitAllBlocking(vararg deferreds: Deferred<T>): List<T>

awaitFirst

suspend fun <T> Flow<T>.awaitFirst(message: String = "", timeout: Duration = defaultTimeout, condition: suspend (T) -> Boolean = { true }): T

captureFor

suspend fun <T> Flow<T>.captureFor(duration: Duration): List<T>

Returns a list of flow items captured for duration

mainBackground

fun mainBackground(args: Array<String>)

testBlockingAndCancelScope

inline fun <T> testBlockingAndCancelScope(context: CoroutineContext = EmptyCoroutineContext, crossinline block: suspend CoroutineScope.() -> T): T

yieldMultiple

suspend fun yieldMultiple(times: Int = DEFAULT_MULTIPLE_TIMES_YIELDS)

Calls yield for a number of times

yieldUntil

suspend fun yieldUntil(timeout: Duration = Duration.INFINITE, timesPerTurn: Int = DEFAULT_MULTIPLE_TIMES_YIELDS, delayPerTurn: Duration = 10.milliseconds, constraint: () -> Boolean)

Calls yield until a constraint is met. After yielding a number of times there is a delay to prevent maxing out the CPU.