Usecase for a observing a chat conversation #279

OrhanTozan · 2021-06-30T13:29:13Z

OrhanTozan
Jun 30, 2021

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()?

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Usecase for a observing a chat conversation #279

Uh oh!

{{title}}

Uh oh!

Replies: 0 comments

Select a reply

Uh oh!

Usecase for a observing a chat conversation #279

Uh oh!

OrhanTozan Jun 30, 2021

Replies: 0 comments

OrhanTozan
Jun 30, 2021