MutableSharedFlow采用3个参数:重播、extraBufferCapacity和onBufferOverflow。重播和extraBufferCapacity有什么区别?
这些文件提到以下几点:
重放-重放给新订阅者的值的数量(不能为负值,默认值为零)。extraBufferCapacity -除了重放之外,缓冲的值的数量。当缓冲区空间仍然存在时,发射不挂起(可选,不能为负,默认值为零)。
我不太明白2和我们何时需要extraBufferCapacity > 0之间的区别。extraBufferCapacity只是一个额外的排放者的重放能力吗?
发布于 2022-03-01 13:39:29
,extraBufferCapacity只是一个额外的排放者的重放能力吗?
“重放”这一术语只对订户有意义,而不适用于排放者。replay
参数定义新订阅者在订阅时将收到多少过去的值。这显然意味着需要存储这些值,所以整个缓冲区至少需要这么大。
但是,缓冲区大小(作为一个整体)会影响发射器。完整缓冲区的确切结果取决于onBufferOverflow
,但是这个缓冲区大小可以用来控制发射器的背压(减慢它们的速度)或我们如何丢弃消息。使用更大的缓冲区,您可以允许排放者在不减慢排放的情况下,像任何常规缓冲器一样,进行连续的排放。
现在,选择一个更大的缓冲区不应该强迫您将这些缓冲值重放给新的订阅者,因此产生了extraBufferCapacity
。使用extraBufferCapacity > 0
,您可以定义任意大小的缓冲区,而不必强制您重放同样多的值,只需使用以下公式:
bufferSize = replay + extraBufferCapacity
例如,您可以决定不向新订阅者重放任何值,但仍然允许通过一些(不重放)缓冲区从发射器中释放。
https://stackoverflow.com/questions/71309128
复制相似问题