kotlinx.coroutines

kotlinx.coroutines copied to clipboard

rx Flowable that use Unconfined dispatcher result in a deadlock when using a runblocking() that execute a suspend function with (Semaphore, mutex or ReentrantLock)

1

Hello, This code result in a deadlock : ``` sharedFlow.asFlowable(Unconfined) .flatMap { runBlocking { suspend function with (Mutex , Semaphore or ReentrantLock) --> This code deadlocks here } } ```...

cchaouachi

Support "worker pool" pattern in actor builder and other related operators

15

`actor` builder should natively support "worker pool" pattern via an additional optional parameter ~parallelism~ `concurrency` that defaults to `1`, so that to you if you have a list of of...

elizarov

Add argument to sample to sample at the start of a flow instead of the end?

5

**Use case** I have a stream of items coming in fairly quickly (30 per second) and according to my PMs I only need to grab the first item, every 5...

ColtonIdle

## Problem The documentation for `Dispatchers.IO` appears to be misleading. Specifically, it suggests that the `kotlinx.coroutines.io.parallelism` system property limits the number of threads, when in fact: - The `kotlinx.coroutines.io.parallelism` property...

kaseken

Draft for now, because the documentation of some other functions should be updated accordingly: * [x] The remaining entries in `CoroutineScope.kt`. * [x] `supervisorScope` * [x] `Builders.common.kt`: `launch`, `async`, and...

dkhalanskyjb

```kotlin runBlocking { cancel() withContext(EmptyCoroutineContext) { println("This will not be printed") } println("Neither will this") } ``` ```kotlin runBlocking { cancel() withTimeout(1.seconds) { println("This will be printed") } println("This will...

dkhalanskyjb

dkhalanskyjb

The `oss.sonatype` repository is being sunset and `maven.pkg.jetbrains.space` is as well. The best way to future-proof is to accept generic repository and username/password and make all the changes in TC...

SmialyKot

Remove outdated kludges

2

Hello! [KT-28938](https://youtrack.jetbrains.com/issue/KT-28938) is fixed since Kotlin 1.3.60, but `Emitters.kt` still has those at 2 places, in the bodies of `transform` and `unsafeTransform`: ```kotlin // kludge, without it Unit will be...

LouisCAD

Introduce SharedFlow.collectLatest

1

Fixes https://youtrack.jetbrains.com/issue/KTIJ-34450

dkhalanskyjb