update MainVM.kt

Author: hoc081098

data/src/main/java/com/hoc/flowmvi/data/DataModule.kt

@@ -7,7 +7,6 @@ import com.hoc.flowmvi.data.remote.UserApiService
 import com.hoc.flowmvi.domain.repository.UserRepository
 import com.squareup.moshi.Moshi
 import com.squareup.moshi.kotlin.reflect.KotlinJsonAdapterFactory
-import java.util.concurrent.TimeUnit
 import kotlinx.coroutines.ExperimentalCoroutinesApi
 import kotlinx.coroutines.FlowPreview
 import okhttp3.OkHttpClient
@@ -17,6 +16,7 @@ import org.koin.core.qualifier.named
 import org.koin.dsl.module
 import retrofit2.Retrofit
 import retrofit2.converter.moshi.MoshiConverterFactory
+import java.util.concurrent.TimeUnit
 import kotlin.time.ExperimentalTime
 
 private const val BASE_URL = "BASE_URL"

feature-main/src/main/java/com/hoc/flowmvi/ui/main/MainVM.kt

@@ -55,7 +55,6 @@ internal class MainVM(
       _intentFlow.filterIsInstance<ViewIntent.Initial>().take(1),
       _intentFlow.filterNot { it is ViewIntent.Initial }
     )
-      .shareIn(viewModelScope, SharingStarted.WhileSubscribed())
       .toPartialChangeFlow()
       .sendSingleEvent()
       .scan(initialVS) { vs, change -> change.reduce(vs) }
@@ -86,7 +85,7 @@ internal class MainVM(
     }
   }
 
-  private fun Flow<ViewIntent>.toPartialChangeFlow(): Flow<PartialChange> {
+  private fun Flow<ViewIntent>.toPartialChangeFlow(): Flow<PartialChange> = shareIn(viewModelScope, SharingStarted.WhileSubscribed()).run {
     val getUserChanges = getUsersUseCase()
       .onEach { Log.d("###", "[MAIN_VM] Emit users.size=${it.size}") }
       .map {