[feature/add-dispatcher] Add dispatcher when mapping data -> domain model in flow

app/build.gradle.kts

@@ -37,6 +37,7 @@ android {
 }
 
 dependencies {
+    implementation(projects.core.common)
     implementation(projects.core.database)
     implementation(projects.core.designsystem)
     implementation(projects.`data`.task)

core/common/.gitignore

@@ -0,0 +1 @@
+/build

core/common/build.gradle.kts

@@ -0,0 +1,14 @@
+@Suppress("DSL_SCOPE_VIOLATION") // TODO: Remove once KTIJ-19369 is fixed
+plugins {
+    id("conf.mad.primitive.android")
+    id("conf.mad.primitive.android.kotlin")
+    id("conf.mad.primitive.android.hilt")
+}
+
+android {
+    namespace = "com.conf.mad.todo.common"
+
+    defaultConfig {
+        consumerProguardFiles("consumer-rules.pro")
+    }
+}

core/common/src/main/AndroidManifest.xml

@@ -0,0 +1,2 @@
+<?xml version="1.0" encoding="utf-8"?>
+<manifest xmlns:android="http://schemas.android.com/apk/res/android" />

core/common/src/main/java/com/conf/mad/todo/common/TodoDispatchers.kt

@@ -0,0 +1,12 @@
+package com.conf.mad.todo.common
+
+import javax.inject.Qualifier
+
+@Qualifier
+@Retention(AnnotationRetention.RUNTIME)
+annotation class Dispatcher(val dispatcherType: DispatcherType)
+
+enum class DispatcherType {
+    DEFAULT,
+    IO,
+}

core/common/src/main/java/com/conf/mad/todo/common/di/DispatchersModule.kt

@@ -0,0 +1,22 @@
+package com.conf.mad.todo.common.di
+
+import com.conf.mad.todo.common.Dispatcher
+import com.conf.mad.todo.common.DispatcherType
+import dagger.Module
+import dagger.Provides
+import dagger.hilt.InstallIn
+import dagger.hilt.components.SingletonComponent
+import kotlinx.coroutines.CoroutineDispatcher
+import kotlinx.coroutines.Dispatchers
+
+@Module
+@InstallIn(SingletonComponent::class)
+object DispatchersModule {
+    @Provides
+    @Dispatcher(DispatcherType.IO)
+    fun providesIODispatcher(): CoroutineDispatcher = Dispatchers.IO
+
+    @Provides
+    @Dispatcher(DispatcherType.DEFAULT)
+    fun providesDefaultDispatcher(): CoroutineDispatcher = Dispatchers.Default
+}

data/task/build.gradle.kts

@@ -12,6 +12,7 @@ android {
 }
 
 dependencies {
+    implementation(projects.core.common)
     implementation(projects.core.database)
     implementation(projects.domain.task)
 }

data/task/src/main/java/com/conf/mad/todo/data/task/repository/DefaultTaskRepository.kt

@@ -1,23 +1,36 @@
 package com.conf.mad.todo.data.task.repository
 
+import com.conf.mad.todo.common.Dispatcher
+import com.conf.mad.todo.common.DispatcherType.DEFAULT
 import com.conf.mad.todo.data.task.mapper.asDomain
 import com.conf.mad.todo.data.task.mapper.toEntity
 import com.conf.mad.todo.database.TaskDao
 import com.conf.mad.todo.task.model.Task
 import com.conf.mad.todo.task.repository.TaskRepository
+import kotlinx.coroutines.CoroutineDispatcher
 import kotlinx.coroutines.flow.Flow
 import kotlinx.coroutines.flow.map
+import kotlinx.coroutines.withContext
 import javax.inject.Inject
 
 class DefaultTaskRepository @Inject constructor(
-    private val taskDao: TaskDao
+    private val taskDao: TaskDao,
+    @Dispatcher(DEFAULT) private val dispatcher: CoroutineDispatcher
 ) : TaskRepository {
     override fun getTodoTasks(): Flow<List<Task>> {
-        return taskDao.getTodoTasks().map { it.asDomain() }
+        return taskDao.getTodoTasks().map {
+            withContext(dispatcher) {
+                it.asDomain()
+            }
+        }
     }
 
     override fun getCompletedTasks(): Flow<List<Task>> {
-        return taskDao.getCompletedTasks().map { it.asDomain() }
+        return taskDao.getCompletedTasks().map {
+            withContext(dispatcher) {
+                it.asDomain()
+            }
+        }
     }
 
     override suspend fun insertTask(task: Task) {

settings.gradle.kts

@@ -18,6 +18,7 @@ dependencyResolutionManagement {
 rootProject.name = "TodoMad"
 include(
     ":app",
+    ":core:common",
     ":core:database",
     ":core:designsystem",
     ":core:ui",