fun messagesFromConversation(conversationId: String): Flow<List<Message>> = channelFlow {
    val messageHistory = getMessageHistory()
    offer(messageHistory)
    val accumulatedMessages = messageHistory.toMutableList()
    val sentMessages: Flow<Message> = sentMessagesFromConversation(conversationId)
    sentMessages.collect { sentMessage ->
        acumulatedMessages.add(0, sentMessage)
        offer(accumulatedMessages)
    }
}

offer

false

send

this

var accumulatedMessages

println

var accumulatedMessages: List<Message> = messageHistory
sentMessages.collect { sentMessage ->
    accumulatedMessages = accumulatedMessages + sentMessage
    send(accumulatedMessages)
}

collect

collect

offer

send

offer

offer

conflate

offer

send

conflate

awaitClose

flow { … }

coroutineScope { … }

flow {}

launch {}

W/System.err: java.lang.IllegalStateException: Flow invariant is violated:
    		Emission from another coroutine is detected.
    		Child of StandaloneCoroutine{Active}@f625a8a, expected child of StandaloneCoroutine{Active}@532c8fb.
    		FlowCollector is not thread-safe and concurrent emissions are prohibited.
    		To mitigate this restriction please use 'channelFlow' builder instead of 'flow'
W/System.err: java.lang.IllegalStateException: Flow invariant is violated:
    		Emission from another coroutine is detected.
    		Child of StandaloneCoroutine{Active}@f625a8a, expected child of StandaloneCoroutine{Active}@532c8fb.
    		FlowCollector is not thread-safe and concurrent emissions are prohibited.
    		To mitigate this restriction please use 'channelFlow' builder instead of 'flow'

FlowCollector is not thread-safe and concurrent emissions are prohibited.
    		To mitigate this restriction please use 'channelFlow' builder instead of 'flow'

channelFlow

withContext(flowContext) {
   // on each code (including mutable state access)
}

Job

asLiveData()

LiveData

ConversationContentSnapshot