Skip to content

Commit cdb1089

Browse files
committed
chore: add dispatcher io to repository
1 parent e6d372a commit cdb1089

File tree

1 file changed

+5
-3
lines changed
  • feature-list-streams/src/main/java/com/codandotv/streamplayerapp/feature_list_streams/list/data

1 file changed

+5
-3
lines changed

feature-list-streams/src/main/java/com/codandotv/streamplayerapp/feature_list_streams/list/data/ListStreamRepository.kt

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,17 +1,19 @@
11
package com.codandotv.streamplayerapp.feature_list_streams.list.data
22

33
import com.codandotv.streamplayerapp.core_networking.handleError.toFlow
4-
import com.codandotv.streamplayerapp.core_networking.handleError.toResult
54
import com.codandotv.streamplayerapp.feature_list_streams.list.domain.model.ListStream
65
import com.codandotv.streamplayerapp.feature_list_streams.list.domain.toListStream
6+
import kotlinx.coroutines.CoroutineDispatcher
7+
import kotlinx.coroutines.Dispatchers
78
import kotlinx.coroutines.flow.*
89

910
interface ListStreamRepository {
1011
suspend fun getMovies(): Flow<List<ListStream>>
1112
}
1213

1314
class ListStreamRepositoryImpl(
14-
private val service: ListStreamService
15+
private val service: ListStreamService,
16+
private val dispatcher: CoroutineDispatcher = Dispatchers.IO,
1517
) : ListStreamRepository {
1618

1719
override suspend fun getMovies(): Flow<List<ListStream>> =
@@ -30,5 +32,5 @@ class ListStreamRepositoryImpl(
3032
)
3133
}.first()
3234
}
33-
}
35+
}.flowOn(dispatcher)
3436
}

0 commit comments

Comments
 (0)