< spierce7> have you tried `ConflatedBroadcastChannel` for b kotlinlang #coroutines

Channels

100daysofkotlin

100daysofkotlin-2021

algolialibraries

android-architecture

android-databinding

androidgithubprojects

androidx-xprocessing

arrow-contributors

beepiz-libraries

cincinnati-user-group

codemash-precompiler

codingconventions

competitive-programming

competitivecoding

compose-android

compose-desktop

compose-ui-showcase

connect-audit-events

cscenter-course-2016

domain-driven-design

effective-kotlin

effectivekotlin

embedded-kotlin

event21-community-content

fb-internal-demo

fluid-libraries

framework-elide

getting-started

github-workflows-kt

graviton-browser

image-processing

intellij-plugins

intellij-tricks

introduce-yourself

java-to-kotlin-refactoring

jhipster-kotlin

jvm-ir-backend-feedback

k2-early-adopters

kotest-contributors

kotlin-by-example

kotlin-data-storage

kotlin-foundation

kotlin-in-action

kotlin-multiplatform-contest

kotlin-pakistan

kotlinforbeginners

kotlingforbeginners

kotlinprogrammers

kotlintest-devs

kotlinultimatechallenge

kotlinx-datetime

lambdaworld_cadiz

language-evolution

language-proposals

leedskotlinusergroup

library-development

machinelearningbawas

myndocs-oauth2-server

navigation-architecture-component

ohio-kotlin-users

pattern-matching

pocketgitclient

practical-functional-programming

prozis-android-backup

python-contributors

realworldkotlin

refactoring-to-kotlin

refreshversions

russian-kotlinasfirst

skia-wasm-interop-temp

sofl-user-group

spring-security

squarelibraries

stayhungrystayfoolish

strife-discord-lib

swagger-gradle-codegen

swiss-user-group

tricity-kotlin-user-group

Title

e

enleur

03/12/2018, 6:01 PM

@spierce7 have you tried

ConflatedBroadcastChannel

for broadcasting?

s

spierce7

03/12/2018, 6:51 PM

My understanding was that

ConflatedBroadcastChannel

is similar to an

AsyncSubject

. What if I wanted something similar to a

PublishSubject

?

e

enleur

03/12/2018, 7:44 PM

Not sure what

PublishSubject

actually does, but in

ConflatedBroadcastChannel

when you publish messages and there are no subscribers, these messages will be lost. Subscribers will get only messages that were posted after their subscription

s

spierce7

03/12/2018, 8:46 PM

Oh? That sounds like a

PublishSubject

then.

e

enleur

03/12/2018, 8:52 PM

Just give it a try 🙂

d

dave08

03/12/2018, 9:33 PM

PublishSubject

==

BroadcastChannel(0)

,

BehaviorSubject

==

ConflatedBroadcastChannel

(which has a buffer of one, which is the latest value of the channel, but there's an open pull request to make this even better...)

👍 2

As far as I remember of Rx, since I dumped it for a while now because of coroutines...

s

spierce7

03/12/2018, 10:20 PM

oh? Maybe I'm misunderstanding the way channels work then.

d

dave08

03/13/2018, 3:14 AM

The pull request is here https://github.com/Kotlin/kotlinx.coroutines/pull/274 , this pull is becoming more like a BehaviorRelay

Did you read the ' Rx Subject vs BroadcastChannel' in https://github.com/Kotlin/kotlinx.coroutines/blob/master/reactive/coroutines-guide-reactive.md

3 Views

#coroutines Join Slack