korlibs-io/korlibs.io.async

Package-level declarations

Types

class AsyncCache

class AsyncCacheGen<T>(gen: suspend (key: String) -> T)

AsyncInmemoryCache

class AsyncInmemoryCache(val timeProvider: TimeProvider = TimeProvider)

AsyncInmemoryEntry

class AsyncInmemoryEntry<T : Any>(val clazz: KClass<T>, val cache: AsyncInmemoryCache, val key: String, val ttl: Duration)

EmptyContinuation

open class EmptyContinuation(val context: CoroutineContext) : Continuation<Unit>

ObservableProperty

class ObservableProperty<T>(initial: T)

Properties

DEBUG_ASYNC_LAUNCH_ERRORS

val DEBUG_ASYNC_LAUNCH_ERRORS: Boolean

DEFAULT_SUSPEND_TEST_TIMEOUT

val DEFAULT_SUSPEND_TEST_TIMEOUT: Duration

DEFAULT_TEST_SYNC_IO

val DEFAULT_TEST_SYNC_IO: Boolean? = false

Functions

fun <T> async(context: CoroutineContext, callback: suspend () -> T): Deferred<T>

fun <T> CoroutineScope.async(callback: suspend () -> T): Deferred<T>

fun <T> asyncAsap(context: CoroutineContext, callback: suspend () -> T): Deferred<T>

fun <T> CoroutineScope.asyncAsap(callback: suspend () -> T): Deferred<T>

asyncImmediately

fun <T> asyncImmediately(context: CoroutineContext, callback: suspend () -> T): Deferred<T>

asyncImmediately

fun <T> CoroutineScope.asyncImmediately(callback: suspend () -> T): Deferred<T>

suspend fun <T> ReceiveChannel<T>.chunks(count: Int): ReceiveChannel<List<T>>

fun launch(context: CoroutineContext, callback: suspend () -> Unit): Job

fun launchAsap(context: CoroutineContext, callback: suspend () -> Unit): Job

fun CoroutineScope.launchAsap(callback: suspend () -> Unit): Job

launchImmediately

fun launchImmediately(context: CoroutineContext, callback: suspend () -> Unit): Job

launchImmediately

fun CoroutineScope.launchImmediately(callback: suspend () -> Unit): Job

fun CoroutineContext.launchUnscoped(block: suspend () -> Unit)

fun CoroutineScope.launchUnscoped(block: suspend () -> Unit)

launchUnscopedAndWait

suspend fun <T> CoroutineContext.launchUnscopedAndWait(block: suspend () -> T): T

ObservableProperty

fun <T> ObservableProperty(prop: KMutableProperty0<T>): ObservableProperty<T>

suspend fun <E> produce(capacity: Int = 0, block: suspend ProducerScope<E>.() -> Unit): ReceiveChannel<E>

fun suspendTest(timeout: Duration? = DEFAULT_SUSPEND_TEST_TIMEOUT, preferSyncIo: Boolean? = null, callback: suspend CoroutineScope.() -> Unit): AsyncEntryPointResult

fun suspendTest(cond: () -> Boolean, timeout: Duration? = DEFAULT_SUSPEND_TEST_TIMEOUT, preferSyncIo: Boolean? = DEFAULT_TEST_SYNC_IO, callback: suspend CoroutineScope.() -> Unit): AsyncEntryPointResult

suspendTestNoBrowser

fun suspendTestNoBrowser(preferSyncIo: Boolean? = DEFAULT_TEST_SYNC_IO, callback: suspend CoroutineScope.() -> Unit): AsyncEntryPointResult

suspendTestNoJs

fun suspendTestNoJs(preferSyncIo: Boolean? = DEFAULT_TEST_SYNC_IO, callback: suspend CoroutineScope.() -> Unit): AsyncEntryPointResult

toAsyncInputStream

fun ReceiveChannel<ByteArray>.toAsyncInputStream(): AsyncInputStream

suspend fun <T> Iterable<T>.toChannel(): ReceiveChannel<T>

suspend fun <T> Flow<T>.toChannel(): ReceiveChannel<T>

suspend fun <T> waitSubscriber(block: ((T) -> Unit) -> Cancellable): T

waitSubscriberCloseable

suspend fun <T> waitSubscriberCloseable(block: ((T) -> Unit) -> AutoCloseable): T

withTimeoutNullable

suspend fun <T> withTimeoutNullable(time: Duration?, block: suspend CoroutineScope.() -> T): T