Adding value

stream-merger/src/main/java/com/josdem/kata/CustomInputStream.java

@@ -1,7 +1,6 @@
 package com.josdem.kata;
 
-public record CustomInputStream(int id) implements Comparable<CustomInputStream> {
-
+public record CustomInputStream(int id, String value) implements Comparable<CustomInputStream> {
     @Override
     public int compareTo(CustomInputStream that) {
         return Integer.compare(this.id, that.id);

stream-merger/src/main/java/com/josdem/kata/CustomOutputStream.java

@@ -5,7 +5,8 @@
 public class CustomOutputStream {
     private final Logger log = Logger.getLogger(this.getClass().getName());
 
-    void storeValue(int value) {
-        log.info("value: " + value);
+    void emitValue(String value) {
+        log.info(value);
     }
+
 }

stream-merger/src/main/java/com/josdem/kata/StreamMerger.java

@@ -7,7 +7,7 @@ public record StreamMerger(Set<CustomInputStream> streams) {
 
     public Set<CustomInputStream> mergeInto(CustomOutputStream stream) {
         TreeSet<CustomInputStream> treeSet = new TreeSet<>(streams);
-        treeSet.forEach(item -> stream.storeValue(item.id()));
+        treeSet.forEach(item -> stream.emitValue(item.value()));
         return treeSet;
     }
 

stream-merger/src/test/java/com/josdem/kata/StreamMergerTest.java

@@ -20,9 +20,9 @@ class StreamMergerTest {
     @Test
     @DisplayName("getting an ordered stream collection")
     void shouldGetOrderedStreamCollection() {
-        CustomInputStream cst1 = new CustomInputStream(2);
-        CustomInputStream cst2 = new CustomInputStream(1);
-        CustomInputStream cst3 = new CustomInputStream(0);
+        CustomInputStream cst1 = new CustomInputStream(2, "awesome!");
+        CustomInputStream cst2 = new CustomInputStream(1, "is");
+        CustomInputStream cst3 = new CustomInputStream(0, "This");
 
         Set<CustomInputStream> streams = new HashSet<>();
         streams.add(cst1);