Update refresh

Author: hoc081098

app/src/main/java/com/hoc/pagination_mvi/data/PostRepositoryImpl.kt

@@ -3,9 +3,7 @@ package com.hoc.pagination_mvi.data
 import com.hoc.pagination_mvi.data.remote.ApiService
 import com.hoc.pagination_mvi.di.ApplicationScope
 import com.hoc.pagination_mvi.domain.dispatchers_schedulers.CoroutinesDispatchersProvider
-import com.hoc.pagination_mvi.domain.entity.Photo
 import com.hoc.pagination_mvi.domain.entity.Post
-import com.hoc.pagination_mvi.domain.repository.PhotoRepository
 import com.hoc.pagination_mvi.domain.repository.PostRepository
 import kotlinx.coroutines.withContext
 import javax.inject.Inject

app/src/main/java/com/hoc/pagination_mvi/ui/main/MainInteractorImpl.kt

@@ -94,22 +94,21 @@ class MainInteractorImpl @Inject constructor(
   ): Observable<Refresh> {
     return rxObservable(dispatchers.main) {
       send(Refresh.Refreshing)
+      try {
+        coroutineScope {
+          val async1 = async { getPostsUseCase(limit = limitPost, start = 0) }
+          val async2 = async { getPhotosUseCase(limit = limitPhoto, start = 0) }
 
-      coroutineScope {
-        val async1 = async { getPostsUseCase(limit = limitPost, start = 0) }
-        val async2 = async { getPhotosUseCase(limit = limitPhoto, start = 0) }
-
-        try {
           send(
             Refresh.Success(
               posts = async1.await().map(::PostVS),
               photos = async2.await().map(::PhotoVS)
             )
           )
-        } catch (e: Exception) {
-          delay(500)
-          send(Refresh.Error(e))
         }
+      } catch (e: Exception) {
+        delay(500)
+        send(Refresh.Error(e))
       }
     }
   }

app/src/main/java/com/hoc/pagination_mvi/ui/main/MainVM.kt

@@ -153,6 +153,10 @@ class MainVM @Inject constructor(
             is PostNextPage.Data -> if (change.posts.isEmpty()) singleEventS.onNext(SingleEvent.HasReachedMaxHorizontal)
             is PostNextPage.Error -> singleEventS.onNext(SingleEvent.GetPostsFailure(change.error))
             PostNextPage.Loading -> Unit
+            ///
+            is Refresh.Success -> singleEventS.onNext(SingleEvent.RefreshSuccess)
+            is Refresh.Error -> singleEventS.onNext(SingleEvent.RefreshFailure(change.error))
+            Refresh.Refreshing -> Unit
           }
         }
     }