kotlinx.coroutines
kotlinx.coroutines copied to clipboard
Kotlin
Library support for Kotlin coroutines
Is there a way to achieve a SharedFlow that will only emit once (`replay = 0` behavior), BUT it would also buffer events until at least one collector is collecting...
We have no operator that prevents subsequent emissions for a certain time after an emission. In RxJava there is `throttleFirst` for that. ```kotlin flow { repeat(10) { emit(it) delay(101) }...
ReactiveX site has a nice visualizations for describing operators called marble diagrams. They often help with understanding of the operator, e.g. for checking specifics of operator behavior, like this one:...
I have a requirement to have a flow that is converted to a `SharedFlow` as multiple downstream subscribers consume the result, but the originating flow is particularly expensive so multiple...
The kdoc for `runBlocking` claims it blocks the thread from which it is called (interuptibly). But I have observed behaviour where other coroutines waiting for dispatch on that thread (e.g....
I noticed a few scenarios with channels where they do not seem to be fair and are filling their buffer in the wrong order. The main gist of the post...
Can we have a `zipWithNext` operator for Flow? Could you help me implement one?
Hello, I keep seeing this suspend functions racing use case being asked on Kotlin's Slack, and I personally need it quite often as it suits many needs in "coroutines-heavy" code....
I'm making extensive use of coroutines, replacing `thread` calls and use structured concurrency as suggested. however I found coroutines very hard to debug. using `org.jetbrains.kotlinx:kotlinx-coroutines-debug:1.6.0` along with `-jdk8`, `-core` both...
