feat : 계속 flow 새로생성해서 반환 -> 리스트를 반환하고 viewModel에서 StateFlow로 관리

Author: koreatlwls

data/src/main/java/com/stop/data/remote/source/nearplace/NearPlaceRemoteDataSource.kt

@@ -5,7 +5,7 @@ import com.stop.data.model.nearplace.Place
 interface NearPlaceRemoteDataSource {
 
     suspend fun getNearPlaces(
-        version : Int,
+        version: Int,
         searchKeyword: String,
         centerLon: Double,
         centerLat: Double,

data/src/main/java/com/stop/data/repository/NearPlaceRepositoryImpl.kt

@@ -3,8 +3,6 @@ package com.stop.data.repository
 import com.stop.data.remote.source.nearplace.NearPlaceRemoteDataSource
 import com.stop.domain.model.nearplace.Place
 import com.stop.domain.repository.NearPlaceRepository
-import kotlinx.coroutines.flow.Flow
-import kotlinx.coroutines.flow.flow
 import javax.inject.Inject
 
 internal class NearPlaceRepositoryImpl @Inject constructor(
@@ -17,18 +15,14 @@ internal class NearPlaceRepositoryImpl @Inject constructor(
         centerLon: Double,
         centerLat: Double,
         appKey: String
-    ): Flow<List<Place>> = flow {
-        emit(
-            nearPlaceRemoteDataSource.getNearPlaces(
-                version,
-                searchKeyword,
-                centerLon,
-                centerLat,
-                appKey
-            ).map {
-                it.toUseCaseModel()
-            }
-        )
+    ): List<Place> = nearPlaceRemoteDataSource.getNearPlaces(
+        version,
+        searchKeyword,
+        centerLon,
+        centerLat,
+        appKey
+    ).map {
+        it.toUseCaseModel()
     }
 
 }

domain/src/main/java/com/stop/domain/repository/NearPlaceRepository.kt

@@ -1,7 +1,6 @@
 package com.stop.domain.repository
 
 import com.stop.domain.model.nearplace.Place
-import kotlinx.coroutines.flow.Flow
 
 interface NearPlaceRepository {
 
@@ -11,6 +10,6 @@ interface NearPlaceRepository {
         centerLon: Double,
         centerLat: Double,
         appKey: String
-    ): Flow<List<Place>>
+    ): List<Place>
 
 }

domain/src/main/java/com/stop/domain/usecase/nearplace/GetNearPlacesUseCase.kt

@@ -1,7 +1,6 @@
 package com.stop.domain.usecase.nearplace
 
 import com.stop.domain.model.nearplace.Place
-import kotlinx.coroutines.flow.Flow
 
 interface GetNearPlacesUseCase {
 
@@ -11,6 +10,6 @@ interface GetNearPlacesUseCase {
         centerLon: Double,
         centerLat: Double,
         appKey: String
-    ) : Flow<List<Place>>
+    ): List<Place>
 
 }

domain/src/main/java/com/stop/domain/usecase/nearplace/GetNearPlacesUseCaseImpl.kt

@@ -2,7 +2,6 @@ package com.stop.domain.usecase.nearplace
 
 import com.stop.domain.model.nearplace.Place
 import com.stop.domain.repository.NearPlaceRepository
-import kotlinx.coroutines.flow.Flow
 import javax.inject.Inject
 
 internal class GetNearPlacesUseCaseImpl @Inject constructor(
@@ -15,7 +14,7 @@ internal class GetNearPlacesUseCaseImpl @Inject constructor(
         centerLon: Double,
         centerLat: Double,
         appKey: String
-    ): Flow<List<Place>> =
+    ): List<Place> =
         nearPlaceRepository.getNearPlaces(
             version,
             searchKeyword,

presentation/src/main/java/com/stop/ui/placesearch/PlaceSearchViewModel.kt

@@ -12,7 +12,8 @@ import com.stop.model.Event
 import com.stop.model.Location
 import dagger.hilt.android.lifecycle.HiltViewModel
 import kotlinx.coroutines.channels.Channel
-import kotlinx.coroutines.flow.collectLatest
+import kotlinx.coroutines.flow.MutableStateFlow
+import kotlinx.coroutines.flow.StateFlow
 import kotlinx.coroutines.flow.receiveAsFlow
 import kotlinx.coroutines.launch
 import javax.inject.Inject
@@ -24,8 +25,8 @@ class PlaceSearchViewModel @Inject constructor(
 
     var currentLocation = Location(0.0, 0.0)
 
-    private val _nearPlaceList = MutableLiveData<List<Place>>()
-    val nearPlaceList: LiveData<List<Place>> = _nearPlaceList
+    private val _nearPlaceList = MutableStateFlow<List<Place>>(emptyList())
+    val nearPlaceList: StateFlow<List<Place>> = _nearPlaceList
 
     private val errorMessageChannel = Channel<String>()
     val errorMessage = errorMessageChannel.receiveAsFlow()
@@ -36,7 +37,6 @@ class PlaceSearchViewModel @Inject constructor(
     private val clickCurrentLocationChannel = Channel<Boolean>()
     val clickCurrentLocation = clickCurrentLocationChannel.receiveAsFlow()
 
-
     fun afterTextChanged(s: Editable?) {
         getNearPlaces(
             s.toString(),
@@ -45,7 +45,7 @@ class PlaceSearchViewModel @Inject constructor(
         )
 
         if (s.toString().isBlank()) {
-            _nearPlaceList.postValue(emptyList())
+            setNearPlaceListEmpty()
         }
     }
 
@@ -56,15 +56,15 @@ class PlaceSearchViewModel @Inject constructor(
     ) {
         viewModelScope.launch {
             try {
-                getNearPlacesUseCase.getNearPlaces(
-                    TMAP_VERSION,
-                    searchKeyword,
-                    centerLon,
-                    centerLat,
-                    BuildConfig.TMAP_APP_KEY
-                ).collectLatest {
-                    _nearPlaceList.value = it
-                }
+                _nearPlaceList.emit(
+                    getNearPlacesUseCase.getNearPlaces(
+                        TMAP_VERSION,
+                        searchKeyword,
+                        centerLon,
+                        centerLat,
+                        BuildConfig.TMAP_APP_KEY
+                    )
+                )
             } catch (e: Exception) {
                 setNearPlaceListEmpty()
                 errorMessageChannel.send(e.message ?: "something is wrong")
@@ -73,7 +73,7 @@ class PlaceSearchViewModel @Inject constructor(
     }
 
     fun setNearPlaceListEmpty() {
-        _nearPlaceList.postValue(emptyList())
+        _nearPlaceList.value = emptyList()
     }
 
     fun setClickPlace(place: Place) {