A modern programming language that makes developers happier.

kotlinlang

Guys, hi. Question: if I want to use something like PublishSubject from Rx, so I can both emit and subscribe to it, what is the analogue in coroutines? Do we still use some kind of Channel or Flow already has this functionality?

`PublishSubject` is a `BroadcastChannel&lt;T&gt;(1)`

`StateFlow`  is the best available tool right now. `SharedFlow`  is more powerful and will be released within the next 2 months.

`BehaviorSubject` can be replaced with a `ConflatedBroadcastChannel`.

Ah. In that case, wait for `SharedFlow`  while you use `BroadcastChannel(1)` .

<@U579VR96E> then `BehaviorSubject` equivalent is `StateFlow` when `ConflatedBroadcastChannel` dissapear

Right, I forgot `StateFlow` is already released and working, I haven’t migrated to it myself yet. It’s a direct replacement for `ConflatedBroadcastChannel(1)`, no (obvious) surprises right?

Just around closing. It cannot (or doesn't have to) be closed (yet?).

It should be I guess <@U579VR96E>, they will deprecate `ConflatedBroadcastChannel` when `StateFlow` is released

I think there is one more difference between `StateFlow` and `ConflatedBroadcastChannel`
In case when you set/emit the same value twice StateFlow won’t emit an update

&gt; `StateFlow` conflation is based on equality like <https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines.flow/distinct-until-changed.html|distinctUntilChanged> operator, unlike conflation in `ConflatedBroadcastChannel` that is based on reference identity.
<https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines.flow/-state-flow/>

Another possible option: <https://github.com/akarnokd/kotlin-flow-extensions#publishsubject|https://github.com/akarnokd/kotlin-flow-extensions#publishsubject>