MutableStateFlow collector doesn't receive data

Issue

I have some view model:

    private val locationFlow = locationProviderClient.locationFlow(LocationModule.locationRequest)

    val position = MutableStateFlow(Location(LocationManager.NETWORK_PROVIDER))
    val positions = MutableStateFlow(emptyList<Position>())

    init {
        collectLocation()
    }

    private fun collectLocation() {
        viewModelScope.launch {
            locationFlow.collect {
                position.value = it
                positions.value = positionService.updateLocation(it.toPosition())
            }
        }
    }

On initialization flow of current location is starting. On each new value last position should be emitted into position state flow and network request should be performed. Here's fragment code responsible for collecting state flows

override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        lifecycleScope.launchWhenStarted {
                ...
                viewModel.positions.collect(updateMarkers)
                viewModel.position.collect(updateCamera)
                ...
            }
    }

Now, when fragment starts location is emitted, both flows are updated, request is send updateMarkers is called but updateCamera is not.

I suppose there is some subtle bug, if no can anybody tell me what the hell I'm doing wrong?

Solution

The collects of your two flows are not concurrent, they are still executed sequentially.

override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        lifecycleScope.launch(Dispatchers.IO) {
                ...
                viewModel.positions.collect(updateMarkers)
                ...
            }

        lifecycleScope.launch(Dispatchers.IO) {
                ...
                viewModel.position.collect(updateCamera)
                ...
            }
    }

Answered By - Future Deep Gone