OY
давайте больше контекста дам, у меня вот такой 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)
}
}для этого будет SharedFlow с reply=0, если я понимаю правильно