feat: SmartValue<T>.map function (#125)

timemates · Mar 24, 2024 · 806b99a · 806b99a
1 parent e61ea52
commit 806b99a
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 0 deletions.
diff --git a/foundation/smart-value/src/commonMain/kotlin/org/timemates/remote/value/MappingSmartValue.kt b/foundation/smart-value/src/commonMain/kotlin/org/timemates/remote/value/MappingSmartValue.kt
@@ -0,0 +1,12 @@
+package org.timemates.remote.value
+
+import kotlinx.coroutines.flow.Flow
+import kotlinx.coroutines.flow.map
+
+internal class MappingSmartValue<T, R>(
+    source: SmartValue<T>,
+    mapper: suspend (T?) -> R?
+) : SmartValue<R> {
+    override val localValue: Flow<R?> = source.localValue.map(mapper)
+    override val remoteValue: Flow<R?> = source.remoteValue.map(mapper)
+}
diff --git a/foundation/smart-value/src/commonMain/kotlin/org/timemates/remote/value/SmartValue.kt b/foundation/smart-value/src/commonMain/kotlin/org/timemates/remote/value/SmartValue.kt
@@ -63,4 +63,8 @@ public interface SmartValue<T> {
             )
         }
     }
+}
+
+public fun <T, R> SmartValue<T>.map(transform: suspend (T?) -> R?): SmartValue<R> {
+    return MappingSmartValue(this, transform)
 }
-Original file line number
+Diff line change
@@ Expand Up / @@ -63,4 +63,8 @@ public interface SmartValue<T> { @@
                 )
             }
         }
+    }
+    public fun <T, R> SmartValue<T>.map(transform: suspend (T?) -> R?): SmartValue<R> {
+        return MappingSmartValue(this, transform)
     }