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)
trafficstars
Hello,
This code result in a deadlock :
sharedFlow.asFlowable(Unconfined)
.flatMap {
runBlocking {
suspend function with (Mutex , Semaphore or ReentrantLock) --> This code deadlocks here
}
}
when we change the Unconfined dispatcher to the Default the problem disappear? is it the intended behavior ? I found a similar issue but with blockingGet