getting some proguard compilation warnings after upgrading to

kotlinx.coroutines 1.2.0

:

Warning: kotlinx.atomicfu.AtomicFU: can't find referenced method 'void setInterceptor(kotlinx.atomicfu.AtomicOperationInterceptor)' in program class kotlinx.atomicfu.InterceptorKt

Proguard is configured as per

kotlinx-coroutines-core/resources/META-INF/proguard/coroutines.pro

. I can easily solve this warning by adding a rule to keep the corresponding atomicfu class and its methods, but i was wondering whether it's safe to

-dontwarn

it. I have no warnings when using v1.1.1. Anyone experiencing a similar issue?

When upgrading to Coroutines 1.2.0, I got this error:

Could not resolve all files for configuration ':kofu-coroutines-mongodb:compileClasspath'.
   > Could not find org.jetbrains.kotlinx:atomicfu:0.12.3.
     Required by:
         project :kofu-coroutines-mongodb > org.jetbrains.kotlinx:kotlinx-coroutines-core:1.2.0
   > Could not find org.jetbrains.kotlinx:atomicfu-common:0.12.3.
     Required by:
         project :kofu-coroutines-mongodb > org.jetbrains.kotlinx:kotlinx-coroutines-core:1.2.0

It seems indeed missing from Maven Central https://search.maven.org/search?q=a:atomicfu Could you publish it ?

Why is there no

io.reactivex.Observable.asFlow

?

If I need a behaviorsubject in the flow world: is a ConflatedBroadcastChannel and exposing it as asFlow() the way to go? Or is there a better equivalent?

Hi everyone. I’m trying to convert callback based api to coroutines. I have converted simple callbacks like onSuccess onFailure with suspendCoroutine call, but i have one method that notify me when some events happens(it like 10 events), i think about to return channel parameterized by sealed class of event from this method. But i can’t call channel send from inside callback method because it not marked as suspend, should i just call launch from every method?

suspend fun PeerConnectionFactory.createPeerConnection

??

hi, i have some questions about kotlin coroutines 1. "suspend fucntion can suspend coroutine but not block a thread", so when coroutine is suspend who is the thread responsible to execute this suspend function ?? 2. what diff between corountineContext.cancel() vs job.cancel() 3. what diff between CoroutineScope.xxx() vs suspend fun xxx()

Does it possible to recover stacktrace with

1.2.0

? Is there a flag to enable it?

I couldn't find information about this message in either the K/N or coroutines repos. Anyone else see this?

From the source, I noticed that calling

flowViaChannel(bufferSize = Channel.CONFLATED) { ... }

throws an

IllegalArgumentException

due to

Channel.CONFLATED

constant value being less than 0. Is it the intended behavior ? The documentation for this function highlights that

Channel.CONFLATED

would be an accepted value : https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines.flow/flow-via-channel.html

Is it possible to iterate over

Flow

just like we can iterate over

ReceiveChannel

?

I've read all about `Flow`s and I still do not understand if/how I can replace channels with flows in my library. I really need to be able to do

.send

on the one side and iterate when reading on the other side, but at the same time I need to transform the data using

map

and

filter

, which are obsolete for channels.

Hmm, this code hangs forever for me using 1.3.30:

withTimeoutOrNull(100) {
    suspendCoroutine<Unit> { cont ->
        (context.getSystemService(Context.INPUT_METHOD_SERVICE) as InputMethodManager)
            .hideSoftInputFromWindow(windowToken, 0, object : ResultReceiver(handler) {
                override fun onReceiveResult(resultCode: Int, resultData: Bundle?) {
                    cont.resume(Unit)
                }
            })
    }
}

are there plans to make

SelectClause0.registerSelectClause0

& friends non-internal API? I want to write my own low-level primitive with select clauses available, but I don't want to touch the internals

Is it possible to have two Coroutines print to the console at the same time (in a queue), while one is reading keyboard input from the console?

Unable to understand this

Where as in this case, the last line "Hello " executes first

Hey guys! I’m wondering if there’s a problem in the comment of

join

function:

If I have a

ReceiveChannel

, is there a way for me to turn it into a

Flow

?

There is no counting semaphore in coroutines yet right? Only

Mutex

?

I've bumped into a guide several weeks ago where `Sequence`s were explained using a visual guide but I can't seem to find it now in Google. Have any of you bumped into that?

hi,

suspend fun ServerSocket.listening() = suspendCancellableCoroutine<Socket>{ 
    it.invokeOnClancellation { println("coroutine is cancelling...."); close() }
    it.resueWith(Result.success(accpet())
}

fun main() = runBlocking() {
     withTimeout(3000) {
           val socket = ServerSocket(4000).run { listening() }
     }
}

i expected to cancel after 3 sec but not think happen, server still listening and wait for client to connect why suspendCancellableCoroutine not cancelled ?? any idea

Hello from what i understood, multiplatform support of coroutine only works when use in main thread? so when i use ktor, the api call is done in main thread and it doesn't freeze the UI due to suspend function use?

do I have to join() coroutine after it’s finished? What happens if I don’t?

As I am browsing through Flow sources, I came across

internal object NullSurrogate

. Is such thing really reasonably needed? I thought that Kotlin can handle nulls pretty well already 🙂

it’s very javascripty in that you have to go back and forth with reference comparison and unchecked casts to make it work, with performance as a big tradeoff compared with a sealed class or a nested Option

Can someone ELI5 hot streams vs cold streams? I'm trying to wrap my head around Flow and I don't quite get it