hoc081098

// FlowRedux is from
https://github.com/hoc081098/GithubSearchKMM-Compose-SwiftUI/tree/master/flowredux/src/commonMain/kotlin/com/hoc081098/flowredux

package com.hoc081098.flowredux.dsl

import com.hoc081098.flowredux.FlowReduxStore
import com.hoc081098.flowredux.SideEffect
import com.hoc081098.flowredux.createFlowReduxStore
import com.hoc081098.flowredux.liftAction
import kotlinx.coroutines.CoroutineScope

hoc081098

package com.example.roomdb;

import android.content.Context;
import android.os.Bundle;
import android.os.Handler;
import android.os.Looper;
import android.util.Log;
import android.view.LayoutInflater;
import android.view.View;
import android.view.ViewGroup;

hoc081098

package com.example.roomdb;

import android.content.Context;
import android.os.Bundle;
import android.os.Handler;
import android.os.Looper;
import android.util.Log;
import android.view.LayoutInflater;
import android.view.View;
import android.view.ViewGroup;

hoc081098

    private void API_Get_List() {

        ExecutorService executor = Executors.newSingleThreadExecutor();
        Handler handler = new Handler(Looper.getMainLooper());

        executor.execute(new Runnable() {
            @Override
            public void run() {

                final StringRequest request = new StringRequest(Request.Method.POST,

hoc081098

package com.example.roomdb;

import android.content.Context;
import android.os.Bundle;
import android.os.Handler;
import android.os.Looper;
import android.util.Log;
import android.view.LayoutInflater;
import android.view.View;
import android.view.ViewGroup;

hoc081098

import 'dart:async';

extension SplitExtension<T> on Stream<T> {
  Stream<T> split() {
    final controllers = <MultiStreamController<T>>[];
    var index = -1;
    var done = false;
    StreamSubscription<T> subscription;

    return Stream.multi(

hoc081098

public class ChannelsEventBus {
    private val _channels = hashMapOf<KClass<*>, Channel<Any>>()

    private fun createChannel(key: KClass<*>) = synchronized(this) { _channels.getOrPut(key) { Channel(Channel.UNLIMITED) } }

    public fun send(event: Any): Unit = createChannel(event::class).trySend(event).let {  }

    @Suppress("UNCHECKED_CAST")
    public fun <T : Any> receiveAsFlow(type: KClass<T>): Flow<T> = flow {
        createChannel(type)

hoc081098

#### Nav

-keepnames class androidx.navigation.fragment.NavHostFragment
-keepnames class * extends android.os.Parcelable
-keepnames class * extends java.io.Serializable

#### OkHttp, Retrofit and Moshi

-dontwarn okhttp3.**

hoc081098

@Composable
private fun LazyListState.rememberIsScrollingUpState(): State<Boolean> {
    var previousIndex by remember(this) { mutableIntStateOf(firstVisibleItemIndex) }
    var previousScrollOffset by remember(this) { mutableIntStateOf(firstVisibleItemScrollOffset) }

    return remember(this) {
        derivedStateOf {
            if (previousIndex != firstVisibleItemIndex) {
                previousIndex > firstVisibleItemIndex

hoc081098

@Composable
fun <T: Any> rememberMutableStateListOf(vararg elements: T): SnapshotStateList<T> {
  return rememberSaveable(
    saver = listSaver(
      save = { stateList ->
        if (stateList.isNotEmpty()) {
          val first = stateList.first()
          if (!canBeSaved(first)) {
            throw IllegalStateException("${first::class} cannot be saved. By default only types which can be stored in the Bundle class can be saved.")