kotlinx.coroutines
kotlinx.coroutines copied to clipboard
Kotlin
Library support for Kotlin coroutines
As discussed in #4212. This is my first proper contribution to Coroutines, so please be nice :) At this stage, my goals are: • Optimal API surface • Correctness I...
Hello folks 👋🏼 I have a pooling use-case and I'd like some operator for repeat operations. ## My use-case ```kotlin // returns Processing, Completed, or Failure fun getTransformationStatus(): Flow {...
Note: This MR requires the following changes in kotlin.git: https://github.com/JetBrains/kotlin/compare/master...sellmair/KT-72086/A-way-to-statically-load-DebugProbesKt-in-production ## Summary The kotlin-stdlib compiles against a stub, which will can be provided by applications statically. ## Related [Substitute kotlin.coroutines.jvm.internal.DebugProbesKt...
The Android sample app linked from the "Guide to UI programming with coroutines" document does not exist. > You can clone [kotlinx.coroutines](https://github.com/Kotlin/kotlinx.coroutines) project from GitHub onto your workstation. The resulting...
From the [runBlocking documentation](https://kotlinlang.org/api/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines/run-blocking.html): > It is designed to bridge regular blocking code to libraries that are written in suspending style, to be used in main functions and in tests...
Note: a major piece of terminology that's changed in this is that when a channel is closed with a cause, it's no longer called a "failed channel". I found it...
Versions: * kotlinx.coroutines 1.9.0 * Kotlin 2.0.20 Running the following code in `commonMain`: ```kotlin import kotlinx.coroutines.delay import kotlin.time.Duration.Companion.seconds suspend fun main() { println("main: before delay") delay(1.seconds) println("main: after delay") }...
**Describe the bug** App crashed with exception. ``` kotlinx.coroutines.CoroutinesInternalError: Fatal exception in coroutines machinery for DispatchedContinuation[Dispatchers.IO, Continuation at app.appella.api.persistence.jooq.KotlinDslContext$transaction$3.invokeSuspend(KotlinDslContext.kt)@cbf1194]. Please read KDoc to 'handleFatalException' method and report this incident to...
How does Apple's implementation of reactive streams compare to Flow? Can we expect a `kotlinx-coroutines-combine` module providing utilities for the Combine Framework? I ask because I have a kotlin multiplatform...
**Use case** I have a SharedFlow, which shares some complex computations with many consumers. Basically, I have two types of consumers: some important internal services of the application and web...
