为何MutableSharedFlow的extraBufferCapacity未缓存预发射值？

是的，你观察到的现象完全正确：在第一个订阅者调用collect前，MutableSharedFlow发射的值不会被存入extraBufferCapacity，这是由它的设计逻辑决定的，和Channel的容量机制存在本质差异。

核心原因：MutableSharedFlow 的两个关键参数 #

MutableSharedFlow 的缓存行为由两个参数共同控制，你混淆了它们的作用：

• replay：控制给新订阅者补发的历史消息数量，默认值为0。只有当replay>0时，即使没有订阅者，发射的前N个消息（N=replay）会被缓存，新订阅者一collect就能拿到这些历史值。
• extraBufferCapacity：仅用于处理已有订阅者时的背压场景——当发射速度超过订阅者的消费速度时，超出部分会存入这个缓冲池，等待订阅者处理。如果没有订阅者，这个参数完全不起作用，发射的消息会直接被丢弃。

你只设置了extraBufferCapacity = Int.MAX_VALUE，但replay保持默认的0，所以collect前发射的消息没有被缓存，自然拿不到。

Channel 的容量机制 #

Channel 的设计更接近传统的消息队列：

• 它的容量是全局的消息缓存上限，只要发送操作没有因为容量满而挂起/失败，消息就会被存入队列，无论此时有没有接收者。
• 后续启动的接收者（collect）可以直接读取队列中缓存的消息，这就是你替换为Channel后能正常拿到值的原因。

修正 MutableSharedFlow 的用法 #

如果需要让新订阅者能拿到collect前发射的消息，你需要设置replay参数，比如：

val sharedFlow = MutableSharedFlow<Int>(
    replay = Int.MAX_VALUE, // 缓存所有历史消息给新订阅者
    extraBufferCapacity = 0 // 背压缓冲可根据需求调整
)

或者根据实际需求设置具体的replay数量，而不是依赖extraBufferCapacity。

内容的提问来源于stack exchange，提问作者Max Maksimillan