Viktor Petrovski
09/16/2021, 3:37 PMAlex Prince
09/16/2021, 5:47 PMViktor Petrovski
09/18/2021, 5:43 AMclass PostsCacheRepositoryImpl : PostsCacheRepository {
private val _postFlow: MutableSharedFlow<Post> = MutableSharedFlow(
replay = 1,
onBufferOverflow = BufferOverflow.DROP_OLDEST
)
override val postFlow: SharedFlow<Post>
get() = _postFlow
override fun publishPostUpdate(post: Post) {
_postFlow.tryEmit(post)
}
}
interface PostsCacheRepository {
val postFlow: SharedFlow<Post>
fun publishPostUpdate(post: Post)
}