What is the idiomatic Kotlin way to achieve this? Couldnt use channels since I cant find a right way...

# announcements

[ec]

What is the idiomatic Kotlin way to achieve this? Couldnt use channels since I cant find a right way to call send,

Untitled

[ec]

Realized I can call send on a channel from GlobalScope.launch {} but it doesnt seem to add too much value over just using BlockingQueue for this case, I guess

[Zach Klippenstein (he/him) [MOD]]

If you want a blocking API, that doesn’t look particularly unidiomatic.

If you want a non-blocking API, which seems to be what you’re really asking about, then just use a Channel(capacity = UNLIMITED) to get an unbounded channel, and use channel.offer instead of channel.send to send to the channel without suspending.

[ec]

Thx for the tip, from performance standpoint is Channels better for Kotlin compiler ? Also considering there will be sh!t tons of data putting(frequent), is it better to have a Channel for each sub. then fanning in to output Channel?

[Zach Klippenstein (he/him) [MOD]]

from performance standpoint is Channels better for Kotlin compiler?

Better than what, using a LinkedBlockingQueue? I don’t think the compiler cares either way. Unlimited-capacity channels are effectively linked blocking queues that suspend instead of block, which lets you scale the number of suspending operations a lot more than blocking ones because they’re not pinned to threads.

As for one vs multi channel performance, I’m not sure. I’d build it the simplest way first, then benchmark + profile, and optimize from there.