Телеграмм чат группы kotlin_lang страница 8913

parrot.ru

Рейтинг популярных групп и каналов

В рейтинге участвует:

групп:

каналов:

Виртуальный сервер на SSD - недорого!

Аренда выделенных и виртуальных серверов (VDS/VPS), хостинг, аренда IP-адресов, администрирование, круглосуточная поддержка

qwarta.ru подробнее

Резервное копирование с проверкой на вирусы!!!

Удобный сервис создания резервных копий на любой сервер сети интернет. Отслеживайте изменения, проверяйте на вирусы. Надежно защитите свой бизнес!

go.backupland.com

Выбираете сервер? Любая конфигурация на заказ!

Аренда физических серверов любых конфигураций под любые запросы - 1С бухгалтерия, игровые сервера, нагруженные проекты, интернет-магазины!

qwarta.ru подробнее

Size: a a a

Kotlin Community

3392 membersпожаловаться на группу

2020 July 08

L

L in Kotlin Community

Alexander Nozik

подписка должна отмениться потому что отменятся родительский скоуп подписки, но тут я не на 100% уверен.

У меня было странное поведение когда именно BroadcastChannel подвешивался в рантайме при схлопывании одного из скоупов, который содержал ReceiveChannel полученный из этого BroadcastChannel, в итоге все остальные подписки переставали получать данные. Лечилось как раз таки через ReceiveChannel.cancel, хотя тоже нет уверенности что это правильное поведение, логично было бы то как вы описали :)

источник

11:36пожаловаться #1

A

Aleksandr in Kotlin Community

val channel = BroadcastChannel<String>(Channel.BUFFERED)
val channel = BroadcastChannel<String>(Channel.CONFLATED)

источник

11:40пожаловаться #2

A

Aleksandr in Kotlin Community

ну или с capacity не меньше чем подписчиков

источник

11:42пожаловаться #3

AN

Alexander Nozik in Kotlin Community

val channel = BroadcastChannel<String>(Channel.BUFFERED)
val channel = BroadcastChannel<String>(Channel.CONFLATED)

Это не решение проблемы. Это обход дедлока, а не разрешение

источник

11:42пожаловаться #4

МR

М R in Kotlin Community

давайте больше контекста дам, у меня вот такой event bus работает на этом.
И закрывать канал не получится просто так, так как нужно закрывать его, когда отменяется подписка, а об этом знает только место вызова.

class Bus<T> {
    private val channel: BroadcastChannel<T> = BroadcastChannel(1)

    fun content(): Flow<T> {
        return channel.openSubscription().receiveAsFlow()
    }

    fun setValue(value: T) {
        channel.offer(value)
    }
}

источник

11:49пожаловаться #5

AN

Alexander Nozik in Kotlin Community

давайте больше контекста дам, у меня вот такой event bus работает на этом.
И закрывать канал не получится просто так, так как нужно закрывать его, когда отменяется подписка, а об этом знает только место вызова.

class Bus<T> {
    private val channel: BroadcastChannel<T> = BroadcastChannel(1)

    fun content(): Flow<T> {
        return channel.openSubscription().receiveAsFlow()
    }

    fun setValue(value: T) {
        channel.offer(value)
    }
}

Ну это понятно. Кстати, это в сторону, но сюда прям просится StateFlow.

источник

11:50пожаловаться #6

AN

Alexander Nozik in Kotlin Community

Там вообще все пргоблемы с закрытием отпадают

источник

11:50пожаловаться #7

МR

М R in Kotlin Community

StateFlow эмитит текущее значение при подписке

источник

11:51пожаловаться #8

AN

Alexander Nozik in Kotlin Community

StateFlow эмитит текущее значение при подписке

да, тут у вас то же самое, будет эмитить то, что загружено в канал

источник

11:52пожаловаться #9

AN

Alexander Nozik in Kotlin Community

Если надо пропустить первый элемент, то всегда можно на сделать drop(1)

источник

11:53пожаловаться #10

МR

М R in Kotlin Community

Alexander Nozik

да, тут у вас то же самое, будет эмитить то, что загружено в канал

в том и дело, что нет
Вот такой вариант ничего не напечатает

val channel = BroadcastChannel<String>(1)
channel.send("0")

scope.launch {
    channel.openSubscription()
        .receiveAsFlow()
        .collect { println("receive $it") }
}

scope.launch {
    channel.openSubscription()
        .receiveAsFlow()
        .collect { println("receive $it") }
}

источник

11:58пожаловаться #11

L

L in Kotlin Community

давайте больше контекста дам, у меня вот такой event bus работает на этом.
И закрывать канал не получится просто так, так как нужно закрывать его, когда отменяется подписка, а об этом знает только место вызова.

class Bus<T> {
    private val channel: BroadcastChannel<T> = BroadcastChannel(1)

    fun content(): Flow<T> {
        return channel.openSubscription().receiveAsFlow()
    }

    fun setValue(value: T) {
        channel.offer(value)
    }
}

Здесь просто добавь onCompletion на созданный тобой Flow с помощью receiveAsFlow прямо внутри функции где отмени созданную с помощью openSubscription подписку, будет работать

источник

12:09пожаловаться #12

L

L in Kotlin Community

А вообще да, @noraltavir прав и StateFlow призваны как раз таки заменить conflated broadcast channel

источник

12:10пожаловаться #13

AN

Alexander Nozik in Kotlin Community

в том и дело, что нет
Вот такой вариант ничего не напечатает

val channel = BroadcastChannel<String>(1)
channel.send("0")

scope.launch {
    channel.openSubscription()
        .receiveAsFlow()
        .collect { println("receive $it") }
}

scope.launch {
    channel.openSubscription()
        .receiveAsFlow()
        .collect { println("receive $it") }
}

Ну сделайте дроп первого элемента в результирующем flow

источник

12:11пожаловаться #14

L

L in Kotlin Community

https://pl.kotl.in/Z_efcveNJ вот поиграться, закоменчены другие варианты отмены, к сожалению код дедлочится, желательно запускать на локале чтоб увидеть весь аутпут. При firstSubscription.cancel() или onCompletion все работает ок, при firstJob.cancel или firstScope.cancel все зависает :)

источник

12:15пожаловаться #15

AN

Alexander Nozik in Kotlin Community

в том и дело, что нет
Вот такой вариант ничего не напечатает

val channel = BroadcastChannel<String>(1)
channel.send("0")

scope.launch {
    channel.openSubscription()
        .receiveAsFlow()
        .collect { println("receive $it") }
}

scope.launch {
    channel.openSubscription()
        .receiveAsFlow()
        .collect { println("receive $it") }
}

Кстати и без дропа работает как вы хотите: https://pl.kotl.in/htUDlz_kq

источник

12:22пожаловаться #16

AN

Alexander Nozik in Kotlin Community

а, нет, вру, дроп нужен: https://pl.kotl.in/dNJ-bpEin

источник

12:23пожаловаться #17

МR

М R in Kotlin Community

А вообще да, @noraltavir прав и StateFlow призваны как раз таки заменить conflated broadcast channel

у них есть различия в поведении

источник

12:43пожаловаться #18

AH

Ayrat Hudaygulov in Kotlin Community

Товарищи, как заставить подобное работать при условии что нельзя избавиться от дженерика? (пример специально упрощён)

источник

12:45пожаловаться #19

AH

Ayrat Hudaygulov in Kotlin Community

ex as E жалуется на unchecked cast

источник

12:46пожаловаться #20