耗材渠道

Question

用例

使用来自ReceiveChannel<T> 的T 项的Android 片段。消费后，Ts 应从 ReceiveChannel<T> 中删除。

我需要一个ReceiveChannel<T> 来支持从中消费物品。它应该起到 FIFO 队列的作用。

我目前从我的用户界面附加到频道，例如：

launch(uiJob) { channel.consumeEach{ /** ... */ } }

我通过调用uiJob.cancel() 分离。

期望的行为：

val channel = Channel<Int>(UNLIMITED)

channel.send(1)
channel.send(2)
// ui attaches, receives `1` and `2`
channel.send(3) // ui immediately receives `3`
// ui detaches
channel.send(4)
channel.send(5)
// ui attaches, receiving `4` and `5`

不幸的是，当我从频道分离时，频道已关闭。这会导致.send(4) 和.send(5) 抛出异常，因为通道已关闭。我希望能够从频道中分离并让它保持可用。我该怎么做？

Channel<Int>(UNLIMITED) 非常适合我的用例，except 在取消订阅时关闭频道。我希望频道保持开放。这可能吗？

Answer 1

Channel.consumeEach 方法调用 Channel.consume 方法，该方法在文档中有这一行：

确保给定块消耗给定通道中的所有元素在块执行后始终调用取消。

所以解决方案就是不使用consume[Each]。例如你可以这样做：

launch(uiJob) { for (it in channel) { /** ... */ } }

Answer 2

您可以使用BroadcastChannel。但是，您需要指定一个有限的大小（例如1），因为BroadcastChannel 不支持UNLIMITED 和0（用于rendez-vous）。

您还可以使用ConflatedBroadcastChannel，它始终为新订阅者提供最新的价值，就像LiveData 所做的那样。

顺便说一句，如果您的新 Fragment 实例只收到最新值，这有什么大不了的吗？如果没有，那么就使用ConflatedBroadcastChannel。否则，BroacastChannels 中没有一个可能适合您的用例（尝试一下，看看您是否得到了您正在寻找的行为）。