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

Commit e2157f3a authored by Alexandre Roux's avatar Alexandre Roux
Browse files

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

This reverts commit 54f9e218.
parent d231e287
Loading
Loading
Loading
Loading
Loading
+8 −4
Original line number Diff line number Diff line
@@ -24,7 +24,6 @@ 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
@@ -177,9 +176,14 @@ class FakeLocationStateUseCase(
                LocationManager.NETWORK_PROVIDER, // TODO: tight this with fakelocation module.
                0L,
                0f,
                listener,
                Looper.getMainLooper()
                listener
            )
            // 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) }
+1 −2
Original line number Diff line number Diff line
@@ -23,7 +23,6 @@ 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
@@ -108,7 +107,7 @@ open class BaseFeature<State : Any, in Action : Any, in Effect : Any, SingleEven
        @Suppress("UNUSED_PARAMETER") logger: Logger
    ) {
        onEach { action ->
            callerCoroutineScope.launch(Dispatchers.IO) {
            callerCoroutineScope.launch {
                actor.invoke(_state.value, action)
                    .onEach { effect ->
                        mutex.withLock {