Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit 54f9e218 authored by Abhishek Aggarwal's avatar Abhishek Aggarwal
Browse files

Revert "Revert "privacycentralapp: use io dispatcher for actors""

 * fc has been fixed in privacymodulee

This reverts commit ff51e6ad.
parent a2ec079c
Loading
Loading
Loading
Loading
+4 −8
Original line number Diff line number Diff line
@@ -24,6 +24,7 @@ import android.location.Location
import android.location.LocationListener
import android.location.LocationManager
import android.os.Bundle
import android.os.Looper
import android.util.Log
import foundation.e.privacycentralapp.data.repositories.LocalStateRepository
import foundation.e.privacycentralapp.domain.entities.LocationMode
@@ -176,14 +177,9 @@ class FakeLocationStateUseCase(
                LocationManager.NETWORK_PROVIDER, // TODO: tight this with fakelocation module.
                0L,
                0f,
                listener
                listener,
                Looper.getMainLooper()
                )
            // locationManager.requestLocationUpdates(
            //     LocationManager.NETWORK_PROVIDER, // TODO: tight this with fakelocation module.
            //     0L,
            //     0f,
            //     listener
            // )

            val location: Location? = locationManager.getLastKnownLocation(LocationManager.NETWORK_PROVIDER)
            location?.let { listener.onLocationChanged(it) }
+2 −1
Original line number Diff line number Diff line
@@ -23,6 +23,7 @@ import foundation.e.flowmvi.MVIView
import foundation.e.flowmvi.Reducer
import foundation.e.flowmvi.SingleEventProducer
import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.channels.Channel
import kotlinx.coroutines.flow.Flow
import kotlinx.coroutines.flow.MutableStateFlow
@@ -107,7 +108,7 @@ open class BaseFeature<State : Any, in Action : Any, in Effect : Any, SingleEven
        @Suppress("UNUSED_PARAMETER") logger: Logger
    ) {
        onEach { action ->
            callerCoroutineScope.launch {
            callerCoroutineScope.launch(Dispatchers.IO) {
                actor.invoke(_state.value, action)
                    .onEach { effect ->
                        mutex.withLock {