val singleScheduler = createSingleScheduler()
        singleScheduler.newExecutor().submit {
            // do something
        }

newExecutor().submit

Executors.newSingleThreadExecutor()

Ktor does not work well in multithreaded environment in Kotlin/Native (it may crash), so please don’t mix Ktor and 

coroutines-interop

reaktive

debounce

timeout

@Test
fun `'debounce' using Main scheduler works`() {
    val timeout = 10L
    val time = getTimeMillis()
    val wasCalled = AtomicBoolean(false)

    observableOf(1, 2, 3, 4, 5)
        .debounce(timeout, mainScheduler)
        .subscribe { value ->
            val elapsed = getTimeMillis() - time
            assertTrue("Should have passed more than $timeout millis, but was $elapsed") { elapsed >= timeout }
            assertEquals(5, value)

            wasCalled.value = true
        }

    await(2*timeout.toInt())
    assertTrue("`subscribe` was not called") { wasCalled.value }
}

kotlin.AssertionError: Should have passed more than 10 millis, but was 1

ioScheduler

computationScheduler

delay

debounce

await

private fun await(millis: Int) {
    NSRunLoop.currentRunLoop.runUntilDate(NSDate.dateWithTimeInterval(millis.toDouble()/1000.0, NSDate.now))
}

export

-jvm

concatMap

@Test
fun Operator_durations() {
    val concatMapDuration = measureTime {
        (1..100).asObservable().concatMap { (1..100).asObservable() }.test().values
    }
    val flatMapDuration = measureTime {
        (1..100).asObservable().flatMap { (1..100).asObservable() }.test().values
    }

    println("Measured: concatMap=$concatMapDuration, flatMap=$flatMapDuration")
}

[iOS] Measured: concatMap=7.68s, flatMap=7.47s
[JVM] Measured: concatMap=122ms, flatMap=36.6ms
[JS ] Measured: concatMap=241ms, flatMap=147ms

TestObservable

InvalidMutabilityException

TestObservableObserver(autoFreeze)

MainScheduler

ReferenceError

coroutines, rxjava2 ,rxjava3

Completable#blockingAwait()

Subject.Status

reaktive

ktor

Completable.blockingAwait()

getValue

setValue

Emitter.setCancellable {}

TestScheduler.isManualProcessing

blockingGet()

JS

Test
fun test_blockingGet() {
    val value = single<Int> { emitter -> emitter.onSuccess(1) }.blockingGet()
    println(value)
}

IllegalStateException: Condition is not supported in JavaScript
	at IllegalStateException.init(../build/js/packages_imported/kotlin/1.3.72/kotlin/exceptions.kt:66)
	at Lock.newCondition(../utils/src/jsMain/kotlin/com/badoo/reaktive/utils/lock/Lock.kt:18)
	at <global>.blockingGet(../reaktive/src/commonMain/kotlin/com/badoo/reaktive/utils/lock/Various.kt:5)

Single

coroutines-interop

val body = suspendCoroutine<String?> { continuation ->
    get("<https://postman-echo.com/get>", headers, query)
        .subscribe(
            onSuccess = { continuation.resume(it) }, 
            onError = { continuation.resumeWithException(it) } 
        )
}

kotlin.native.concurrent.FreezingException: freezing of $subscribe_2$<anonymous>_67$FUNCTION_REFERENCE$1621@e3e09f38 has failed, first blocker is EventLoopImpl@1c250dc8

singleFromCoroutine

coroutines-interop