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

Commit bb532e4e authored by Hasib Prince's avatar Hasib Prince
Browse files

fixed: lint issues

parent 730f511a
Loading
Loading
Loading
Loading
Loading
+0 −1
Original line number Diff line number Diff line
@@ -55,7 +55,6 @@ import foundation.e.apps.utils.eventBus.AppEvent
import foundation.e.apps.utils.eventBus.EventBus
import foundation.e.apps.utils.exceptions.GPlayValidationException
import foundation.e.apps.utils.modules.CommonUtilsFunctions
import foundation.e.apps.utils.modules.CommonUtilsModule
import kotlinx.coroutines.flow.collectLatest
import kotlinx.coroutines.flow.filter
import kotlinx.coroutines.launch
+5 −6
Original line number Diff line number Diff line
@@ -53,15 +53,14 @@ import foundation.e.apps.utils.enums.Type
import foundation.e.apps.utils.enums.User
import foundation.e.apps.utils.enums.isInitialized
import foundation.e.apps.utils.enums.isUnFiltered
import foundation.e.apps.utils.modules.CommonUtilsModule
import foundation.e.apps.utils.modules.DataStoreModule
import foundation.e.apps.utils.modules.PWAManagerModule
import java.io.ByteArrayOutputStream
import javax.inject.Inject
import kotlinx.coroutines.channels.ProducerScope
import kotlinx.coroutines.channels.awaitClose
import kotlinx.coroutines.flow.callbackFlow
import kotlinx.coroutines.launch
import java.io.ByteArrayOutputStream
import javax.inject.Inject

@HiltViewModel
class MainActivityViewModel @Inject constructor(
@@ -394,9 +393,9 @@ class MainActivityViewModel @Inject constructor(
        val capabilities = connectivityManager.getNetworkCapabilities(connectivityManager.activeNetwork)

        val hasInternet =
            capabilities != null
                    && capabilities.hasCapability(NetworkCapabilities.NET_CAPABILITY_INTERNET)
                    && capabilities.hasCapability(NetworkCapabilities.NET_CAPABILITY_VALIDATED)
            capabilities != null &&
                capabilities.hasCapability(NetworkCapabilities.NET_CAPABILITY_INTERNET) &&
                capabilities.hasCapability(NetworkCapabilities.NET_CAPABILITY_VALIDATED)

        trySend(hasInternet)
    }
+11 −7
Original line number Diff line number Diff line
@@ -61,11 +61,17 @@ import foundation.e.apps.utils.enums.Type
import foundation.e.apps.utils.enums.isUnFiltered
import foundation.e.apps.utils.modules.PWAManagerModule
import foundation.e.apps.utils.modules.PreferenceManagerModule
import kotlinx.coroutines.*
import kotlinx.coroutines.Deferred
import kotlinx.coroutines.TimeoutCancellationException
import kotlinx.coroutines.async
import kotlinx.coroutines.coroutineScope
import kotlinx.coroutines.withTimeout
import timber.log.Timber
import javax.inject.Inject
import javax.inject.Singleton

typealias FusedHomeDeferred = Deferred<ResultSupreme<List<FusedHome>>>

@Singleton
class FusedAPIImpl @Inject constructor(
    private val cleanAPKRepository: CleanAPKRepository,
@@ -120,9 +126,9 @@ class FusedAPIImpl @Inject constructor(
    ): LiveData<ResultSupreme<List<FusedHome>>> {

        val list = mutableListOf<FusedHome>()
        var resultGplay: Deferred<ResultSupreme<List<FusedHome>>>? = null
        var resultOpenSource: Deferred<ResultSupreme<List<FusedHome>>>? = null
        var resultPWA: Deferred<ResultSupreme<List<FusedHome>>>? = null
        var resultGplay: FusedHomeDeferred? = null
        var resultOpenSource: FusedHomeDeferred? = null
        var resultPWA: FusedHomeDeferred? = null

        return liveData {
            coroutineScope {
@@ -148,9 +154,7 @@ class FusedAPIImpl @Inject constructor(
                resultPWA?.await()?.let {
                    emit(it)
                }

            }

        }
    }

+9 −6
Original line number Diff line number Diff line
@@ -99,14 +99,17 @@ abstract class TimeoutFragment(@LayoutRes layoutId: Int) : Fragment(layoutId) {
     * is disconnected and reconnected multiple times.
     */
    private fun LiveData<Boolean>.loadDataOnce(lifecycleOwner: LifecycleOwner, observer: Observer<Boolean>) {
        observe(lifecycleOwner, object : Observer<Boolean> {
        observe(
            lifecycleOwner,
            object : Observer<Boolean> {
                override fun onChanged(t: Boolean) {
                    observer.onChanged(t)
                    if (t) {
                        removeObserver(this)
                    }
                }
        })
            }
        )
    }

    /**