kotlinx.coroutines
kotlinx.coroutines copied to clipboard
Kotlin
Library support for Kotlin coroutines
The `CoroutineStart.ATOMIC` option was marked experimental almost 6 years ago as part of version 0.30.0. Is there a strong reason that the option is still experimental, or could it be...
One of the pieces of https://github.com/Kotlin/kotlinx.coroutines/issues/4133. Each file can be reviewed independently (and changes to other files will be added later). I'm keeping this a single pull request to avoid...
Possibly related to #2683. Hi, we have had a [bug report](https://issuetracker.google.com/issues/303474263) where users are seeing an exception from Mutex bubble up. Here's the stack trace a user shared: ``` kotlinx.coroutines.CompletionHandlerException:...
I've been working on some code that uses a custom implementation of `CoroutineDispatcher` for testing. Our test dispatcher uses fake time, and runs everything on a single thread to ensure...
I'm trying to bump up coroutines 1.6.4 and many issues come up when bumping up from versions 1.6.4 to 1.8.1, I have tried to change runTest { } to runBlocking...
It looks like under some race conditions using the Flow.catch operator skips upstream exceptions. For example: ```kotlin try { flow { // some work... throw RuntimeException() }.catch { // this...
**Describe the bug** Given a shared `CompletableFuture` object `future`: 1. Attach other transformations on `future`, e.g. `val didRun = AtomicBoolean(); future.whenComplete { _, _ -> didRun.set(true) }` 2. Call `future.asDeferred()`...
**Use case** I want to build a ActorCoroutine via a Channel with Conflated Behavior and capacity. Reading the documentation, Channel should be build with capacity > 0 and, BufferOverFlow.DROP_OLDEST or...
I'm seeing this when testing with Bazel. The failing case seems somewhat unnecessary since the function being tested is @Deprecated. ``` org.junit.ComparisonFailure: expected: but was: at org.junit.Assert.assertEquals(Assert.java:117) at kotlin.test.junit.JUnitAsserter.assertEquals(JUnitSupport.kt:32) at...
