ObjectMapper.toJsonNode() Collector Stream Support

src/main/java/tools/jackson/databind/ObjectMapper.java

@@ -10,6 +10,7 @@
 import java.util.Map;
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.atomic.AtomicReference;
+import java.util.stream.Collector;
 
 import tools.jackson.core.*;
 import tools.jackson.core.exc.StreamReadException;

src/main/java/tools/jackson/databind/util/JacksonCollectors.java

@@ -0,0 +1,38 @@
+package tools.jackson.databind.util;
+
+import java.util.stream.Collector;
+import tools.jackson.databind.JsonNode;
+import tools.jackson.databind.node.ArrayNode;
+import tools.jackson.databind.node.JsonNodeFactory;
+
+/**
+ * Utility class that provides custom {@link Collector} implementations to support Stream operations.
+ * <p>
+ * This class is not meant to be instantiated and serves only as a utility class.
+ * </p>
+ */
+public class JacksonCollectors {
+
+    private JacksonCollectors() {
+        throw new UnsupportedOperationException("Utility class cannot be instantiated.");
+    }
+
+    /**
+     * Creates a {@link Collector} that collects {@link JsonNode} elements into an {@link ArrayNode}.
+     * <p>
+     * This method uses a {@link JsonNodeFactory} to create an empty {@link ArrayNode} and then adds each
+     * {@link JsonNode} to it.
+     * </p>
+     *
+     * @return a {@link Collector} that collects {@link JsonNode} elements into an {@link ArrayNode}
+     */
+    public static Collector<JsonNode, ArrayNode, ArrayNode> toJsonNode() {
+        final JsonNodeFactory jsonNodeFactory = new JsonNodeFactory();
+
+        return Collector.of(
+            jsonNodeFactory::arrayNode, // supplier
+            ArrayNode::add, // accumulator
+            ArrayNode::addAll // combiner
+        );
+    }
+}

src/test/java/tools/jackson/databind/ObjectMapperTest.java

@@ -7,6 +7,7 @@
 import java.nio.charset.StandardCharsets;
 import java.nio.file.*;
 import java.util.*;
+import java.util.stream.IntStream;
 import java.util.stream.Collectors;
 import java.util.zip.ZipOutputStream;
 

src/test/java/tools/jackson/databind/util/JacksonCollectorsTest.java

@@ -0,0 +1,35 @@
+package tools.jackson.databind.util;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertFalse;
+
+import java.util.stream.IntStream;
+import org.junit.jupiter.api.Test;
+import tools.jackson.databind.JsonNode;
+import tools.jackson.databind.ObjectMapper;
+import tools.jackson.databind.node.ObjectNode;
+
+public class JacksonCollectorsTest {
+
+    @Test
+    public void testToJsonNode()
+    {
+        final ObjectMapper objectMapper = new ObjectMapper();
+
+        final JsonNode jsonNodeResult = IntStream.range(0, 10)
+            .mapToObj(i -> {
+                ObjectNode objectNode = objectMapper.createObjectNode();
+                objectNode.put("testString", "example");
+                objectNode.put("testNumber", i);
+                objectNode.put("testBoolean", true);
+
+                return objectNode;
+            })
+            .collect(JacksonCollectors.toJsonNode());
+
+        System.out.println(jsonNodeResult.toPrettyString());
+
+        assertEquals(10, jsonNodeResult.size());
+        jsonNodeResult.forEach(jsonNode -> assertFalse(jsonNode.isEmpty()));
+    }
+}