kotlinx.coroutines
kotlinx.coroutines copied to clipboard
Kotlin
Library support for Kotlin coroutines
``` val popupVm: StateFlow = ... // view model launch(Dispatchers.Swing) { popupVm.collectLatest { data -> if (data == null) { return@collectLatest } val popup = createPopup(data) currentCoroutineContext().job. invokeOnCompletion { //...
**What do we have now?** `runBlocking` parks the thread holding the CPU-token if it happens on a thread of `Dispatchers.Default`. **What should be instead?** `runBlocking` should let go of the...
* Document internal invariants * Add memory footprint test * This explanation can be used to reasonably review follow-up PR that gets rid of addLastIf
…is enabled See #3677 and #2234 for the rationale Fixes #2234
This is a draft because it is a big binary-compatibility-breaking change. I was hoping to start a discussion about this so that we could evolve this to some form that's...
Add two operators for size- and time-based chunking of Flows. Targets issues: https://github.com/Kotlin/kotlinx.coroutines/issues/1290 https://github.com/Kotlin/kotlinx.coroutines/issues/1302 New operators: `public fun Flow.chunked(maxSize: Int, minSize: Int = 1)` `public fun Flow.chunked( chunkDuration: Duration, minSize:...
Log4J 2 has a ThreadContext, which works the same way as SLF4J's MDC. Using the ThreadContext directly with coroutines breaks, but the same approach for an integration that exists for...
**Use case:** The processing of one flow (the operator's receiver) requires using the latest value emitted from another flow at the time of emission from the first flow. My specific...
The aim of this PR is to bring the ability to `sample` a `flow` with the emissions from another flow. I've a extension methods to `Flow`: `Flow.sampleBy(sampler:ReceiveChannel)` which samples a...
