tasks.forEach{ it.await() }

throws the first exception

pretty much always

But I’m never sure if it’s just me being bad xD

according to the release notes "Removed kotlinx-coroutines-io module from the project, it has moved to kotlinx-io."

most likely

How do you debug coroutines, guys? Variables either do not show up at all, or show up with weird names

hey @diesieben07

so about that problem with the firebase.getTokenId being asynchronous and my program depending on it to come back to go on with <very important stuff>

here’s the code where this initialization is happening https://pastebin.com/CjFxiguL

Let's use a thread or a DM

Is there a reason for

block

in

suspend fun read(min: Int = 1, block: (ByteBuffer) -> Unit)

in

kotlinx.coroutines.experimental.io.ByteReadChannel

not being a

suspend

lambda?

I try to implement a non-blocking

ByteReadChannel

to

AsynchronousFileChannel

copy and want to call

AsynchronousFileChannel.aWrite

inside

block

(In gradle build)

Is it possible for a Channel to know when someone is suspending on its

receive()

?

When I try to use the kotlinx.corutines

launch

method in my 1.3 project I am getting this error

📣 📣 📣

kotlinx.coroutines

version

0.25.3

is released to fix Android woes with multi-release jars, more details here: https://github.com/Kotlin/kotlinx.coroutines/releases/tag/0.25.3

📣

kotlinx.coroutines

version

0.25.3-eap13

is built with Kotlin

1.3-M2

and Kotlin/Native

0.9

for preview of graduated (non-experimental) coroutines.

@aaverin Here’s an example on how you could handle Exceptions with a broadcast channel

I wanna do atomic read of an object's property what is recommended way; I can see

AtomicOp

but what is the right way to do it without doing it in

suspend

function

and using mutex

@v0ldem0rt I think this is what you’re looking for: https://github.com/Kotlin/kotlinx.coroutines/blob/master/coroutines-guide.md#mutual-exclusion

@Seri I know the mutex solution I was wondering something that can give me constructs to do atomic reads

Something like

AtomicInt

,

AtomicLong

,

AtomicNativePtr

and

AtomicReference

, then?

Yes

But is it good idea to use AtomicReference in a coroutine

?

A lot of the coroutine stuff is implemented using https://github.com/Kotlin/kotlinx.atomicfu, maybe something in there would work for you? Has Kotlin versions of Java’s Atomics

So I am looking at the implementation of AtmoicInt and others seems like they are using cas operations too

How can I combine values of multiple channels? I'm trying to do sth like

Observable.combineLatest