What is equivalent to RxJava PublishSubject in coroutine channels?

# coroutines

[rmyhal]

What is equivalent to RxJava PublishSubject in coroutine channels?

[orafaaraujo]

I’m using BroadcastChannel<Any>(1)
Where Any is your object

[orafaaraujo]

1 is for any positive number less the max of int

[orafaaraujo]

https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines.channels/-broadcast-channel.html

[andylamax]

Isn't BroadcastChannel<T> deprecated in favor of flow ?

[orafaaraujo]

I think we don’t have any Flow that acts as a PublichSubject until now

[orafaaraujo]

But we’ll have something similar soon

[flosch]

Not until https://github.com/Kotlin/kotlinx.coroutines/issues/2034 is merged

[orafaaraujo]

Thanks, @flosch!

[rmyhal]

Thanks @orafaaraujo

[wasyl]

This is what we’ve used to migrate from RxJava, to make it easier to see the parallel API

typealias PublishChannel<T> = BroadcastChannel<T>

typealias BehaviorChannel<T> = ConflatedBroadcastChannel<T>

fun <T> publishChannel(): PublishChannel<T> = BroadcastChannel(1)

fun <T> behaviorChannel(defaultValue: T? = null): BehaviorChannel<T> =
    defaultValue?.let { ConflatedBroadcastChannel(it) } ?: ConflatedBroadcastChannel()

[orafaaraujo]

Nice approach 😉

[travis]

A possible option until official support is available: https://github.com/akarnokd/kotlin-flow-extensions#publishsubject