@@ -3,6 +3,7 @@ package com.hoc081098.paginationmviflow.ui.main
33import com.hoc081098.flowext.flatMapFirst
44import com.hoc081098.flowext.withLatestFrom
55import com.hoc081098.paginationmviflow.FlowTransformer
6+ import com.hoc081098.paginationmviflow.ui.main.MainContract.PartialStateChange
67import kotlinx.coroutines.ExperimentalCoroutinesApi
78import kotlinx.coroutines.FlowPreview
89import kotlinx.coroutines.flow.StateFlow
@@ -18,7 +19,7 @@ import com.hoc081098.paginationmviflow.ui.main.MainContract.ViewState as VS
1819class MainProcessors @Inject constructor(
1920 private val interactor : MainContract .Interactor ,
2021) {
21- internal fun getInitialProcessor (stateFlow : StateFlow <VS >): FlowTransformer <VI .Initial , MainContract . PartialStateChange > =
22+ internal fun getInitialProcessor (stateFlow : StateFlow <VS >): FlowTransformer <VI .Initial , PartialStateChange > =
2223 FlowTransformer { intents ->
2324 intents
2425 .withLatestFrom(stateFlow)
@@ -31,7 +32,7 @@ class MainProcessors @Inject constructor(
3132 }
3233 }
3334
34- internal fun getNextPageProcessor (stateFlow : StateFlow <VS >): FlowTransformer <VI .LoadNextPage , MainContract . PartialStateChange > =
35+ internal fun getNextPageProcessor (stateFlow : StateFlow <VS >): FlowTransformer <VI .LoadNextPage , PartialStateChange > =
3536 FlowTransformer { intents ->
3637 intents
3738 .withLatestFrom(stateFlow)
@@ -45,7 +46,7 @@ class MainProcessors @Inject constructor(
4546 }
4647 }
4748
48- internal fun getRetryLoadPageProcessor (stateFlow : StateFlow <VS >): FlowTransformer <VI .RetryLoadPage , MainContract . PartialStateChange > =
49+ internal fun getRetryLoadPageProcessor (stateFlow : StateFlow <VS >): FlowTransformer <VI .RetryLoadPage , PartialStateChange > =
4950 FlowTransformer { intents ->
5051 intents
5152 .withLatestFrom(stateFlow)
@@ -59,7 +60,7 @@ class MainProcessors @Inject constructor(
5960 }
6061 }
6162
62- internal fun getLoadNextPageHorizontalProcessor (stateFlow : StateFlow <VS >): FlowTransformer <VI .LoadNextPageHorizontal , MainContract . PartialStateChange > =
63+ internal fun getLoadNextPageHorizontalProcessor (stateFlow : StateFlow <VS >): FlowTransformer <VI .LoadNextPageHorizontal , PartialStateChange > =
6364 FlowTransformer { intents ->
6465 intents
6566 .withLatestFrom(stateFlow)
@@ -68,7 +69,7 @@ class MainProcessors @Inject constructor(
6869 .flatMapFirst { interactor.postNextPageChanges(start = it, limit = MainVM .POST_PAGE_SIZE ) }
6970 }
7071
71- internal fun getRetryLoadPageHorizontalProcessor (stateFlow : StateFlow <VS >): FlowTransformer <VI .RetryLoadPageHorizontal , MainContract . PartialStateChange > =
72+ internal fun getRetryLoadPageHorizontalProcessor (stateFlow : StateFlow <VS >): FlowTransformer <VI .RetryLoadPageHorizontal , PartialStateChange > =
7273 FlowTransformer { intents ->
7374 intents
7475 .withLatestFrom(stateFlow)
@@ -77,15 +78,15 @@ class MainProcessors @Inject constructor(
7778 .flatMapFirst { interactor.postNextPageChanges(start = it, limit = MainVM .POST_PAGE_SIZE ) }
7879 }
7980
80- internal fun getRetryHorizontalProcessor (stateFlow : StateFlow <VS >): FlowTransformer <VI .RetryHorizontal , MainContract . PartialStateChange > =
81+ internal fun getRetryHorizontalProcessor (stateFlow : StateFlow <VS >): FlowTransformer <VI .RetryHorizontal , PartialStateChange > =
8182 FlowTransformer { intents ->
8283 intents
8384 .withLatestFrom(stateFlow)
8485 .filter { (_, vs) -> vs.shouldRetryHorizontal() }
8586 .flatMapFirst { interactor.postFirstPageChanges(limit = MainVM .POST_PAGE_SIZE ) }
8687 }
8788
88- internal fun getRefreshProcessor (stateFlow : StateFlow <VS >): FlowTransformer <VI .Refresh , MainContract . PartialStateChange > =
89+ internal fun getRefreshProcessor (stateFlow : StateFlow <VS >): FlowTransformer <VI .Refresh , PartialStateChange > =
8990 FlowTransformer { intents ->
9091 intents
9192 .withLatestFrom(stateFlow)
0 commit comments