Multiple emissions in a row in flow about grpc-kotlin

[lowasser]

Can you elaborate more about how the client is receiving the responses? Is the client also using the Kotlin bindings?

[Xtizainy]

Sure. Here is the code of client

val updates = MutableLiveData<RoomUpdates>()
fun listenToServer(){
    val requests = channelFlow<JoinRoomRequest> {
            requestsScope = this

            enterRoom(roomId)

            awaitClose {
                runBlocking { updates.postValue(RoomClosed) }
            }
        }

        try {
            roomService.joinRoom(requests).collect { response ->
                when (response.eventCase) {
                    JoinRoomResponse.EventCase.ROOM_UPDATED -> {
                        updates.postValue(RoomUpdated())
                    }

                    ...

                    else -> Timber.e("Unknown host room event: ${response.eventCase}")
                }
            }
        } catch (throwable: Throwable) {
            Timber.e(throwable)
        } finally {
            requestsScope.close()
        }
}

[Xtizainy]

Found the cause - liveData stores only last value. Changing updates val to Channel fixed the problem.
Sorry for interruption