kotlin - Kotlin流重播功能

Question

是否有计划或现有的方式在Kotlin Flow中复制RX的重播/引用计数功能？

我需要在广播 channel 的多播功能(这样，消费者就不会为事件而战)和常规 channel 的缓存/暂停功能(这样，消费者会收到一些积压的事件)之间进行交互。

Answer 1

也许有点晚，但仍然可能有用。
有一个open issue可以实现这种行为，所以我们迟早会得到它。另外，还有关于connectable flow的讨论，但是我看不到他们是否实现它的决定。

UPD:看起来KEEP-1261已过时，而1716现在更相关。