Usecase for a observing a chat conversation

[OrhanTozan]

Let's say I have a chat API. It has two functions:

• suspend fun getAllMessagesOfConversations(conversationId: Int): List<Message>
  • Is a one-shot function that fetches all chat messages of a conversation from the network
• fun incomingMessagesOfConversation(conversationId: Int): Flow<Message>
  • Is a function that returns a never-ending flow of incoming messages from the network

Now I want to abstract this and put it behind a Store, with a Source of Truth and in-memory etc. all the good stuff. I want a Flow<List<Message>> that represents all the messages of conversation, updated when a new incoming message was added.
What would be the way to implement this?

This is my implementation suggestion:

StoreBuilder.from<Int, List<Message>>(
    fetcher = Fetcher.ofFlow { conversationId: Int ->
        channelFlow {
              var messages: List<Message> = getAllMessagesOfConversations(conversationId)
              trySend(messages)
              incomingMessagesOfConversation(conversationId).collect { incomingMessage ->
                    messages = messages + incomingMessage
                    trySend(messages)
              }
        }
    },
    sourceOfTruth = ...,
)

However, does this mean that it will refetch the entire conversation, everytime I'm streaming with StoreRequest.cached()?