From 0f711be5af4312d45e790719d5ebd386d30a0ce9 Mon Sep 17 00:00:00 2001 From: sangyoon Date: Wed, 3 Apr 2024 17:26:00 +0900 Subject: [PATCH] Fix Change the way data is created in flow ([#1327]) --- .../core/testing/repository/TestRecentSearchRepository.kt | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/core/testing/src/main/kotlin/com/google/samples/apps/nowinandroid/core/testing/repository/TestRecentSearchRepository.kt b/core/testing/src/main/kotlin/com/google/samples/apps/nowinandroid/core/testing/repository/TestRecentSearchRepository.kt index f700bdc31..dbd30a3cf 100644 --- a/core/testing/src/main/kotlin/com/google/samples/apps/nowinandroid/core/testing/repository/TestRecentSearchRepository.kt +++ b/core/testing/src/main/kotlin/com/google/samples/apps/nowinandroid/core/testing/repository/TestRecentSearchRepository.kt @@ -19,14 +19,16 @@ package com.google.samples.apps.nowinandroid.core.testing.repository import com.google.samples.apps.nowinandroid.core.data.model.RecentSearchQuery import com.google.samples.apps.nowinandroid.core.data.repository.RecentSearchRepository import kotlinx.coroutines.flow.Flow -import kotlinx.coroutines.flow.flowOf +import kotlinx.coroutines.flow.flow class TestRecentSearchRepository : RecentSearchRepository { private val cachedRecentSearches: MutableList = mutableListOf() override fun getRecentSearchQueries(limit: Int): Flow> = - flowOf(cachedRecentSearches.sortedByDescending { it.queriedDate }.take(limit)) + flow { + emit(cachedRecentSearches.sortedByDescending { it.queriedDate }.take(limit)) + } override suspend fun insertOrReplaceRecentSearch(searchQuery: String) { cachedRecentSearches.add(RecentSearchQuery(searchQuery))