map.foreach uten key

navikt · Mar 14, 2024 · 0cc188a · 0cc188a
1 parent e201bb4
commit 0cc188a
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/kafka-streams/main/libs/kafka/stream/MappedStream.kt b/kafka-streams/main/libs/kafka/stream/MappedStream.kt
@@ -75,4 +75,9 @@ class MappedStream<T : Any> internal constructor(
         val named = Named.`as`("foreach-${namedSupplier()}")
         stream.foreach(mapper, named)
     }
+
+    fun forEach(mapper: (value: T) -> Unit) {
+        val named = Named.`as`("foreach-${namedSupplier()}")
+        stream.foreach { _, value -> mapper(value) }
+    }
 }