logic/com.wire.kalium.logic.data.sync/InMemoryIncrementalSyncRepository/incrementalSyncState

incrementalSyncState

open override val incrementalSyncState: <Error class: unknown class>

Buffered flow of IncrementalSyncStatus.

  • Has a replay size of 1, so the latest value is always immediately available for new observers.

  • Doesn't emit repeated values.

  • It has a limited buffer of size BUFFER_SIZE that will drop the oldest values if the buffer is full to prevent emissions from being suspended due to slow collectors.

See also

BufferOverflow