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;
@@ -563,6 +564,31 @@ public Collection<JacksonModule> getRegisteredModules() {
         return _savedBuilderState.modules();
     }
 
+    /*
+    /**********************************************************************
+    /* Collectors for Stream support.
+    /**********************************************************************
+    */
+
+    /**
+     * Creates a {@link Collector} that collects {@link JsonNode} elements into an {@link ArrayNode}.
+     * <p>
+     * This method uses this instance of {@link ObjectMapper} 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}
+     *
+     * @since 3.0
+     */
+    public Collector<JsonNode, ArrayNode, ArrayNode> toJsonNode() {
+        return Collector.of(
+            this::createArrayNode, // supplier
+            ArrayNode::add, // accumulator
+            ArrayNode::addAll // combiner
+        );
+    }
+
     /*
     /**********************************************************************
     /* Public API: constructing Parsers that are properly linked

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;
 
@@ -100,6 +101,28 @@ public void testProps()
         assertSame(nf, m.getNodeFactory());
     }
 
+    @Test
+    public void testCollector()
+    {
+        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(objectMapper.toJsonNode());
+
+        System.out.println(jsonNodeResult.toPrettyString());
+
+        assertEquals(10, jsonNodeResult.size());
+        jsonNodeResult.forEach(jsonNode -> assertFalse(jsonNode.isEmpty()));
+    }
+
     // Test to ensure that we can check property ordering defaults...
     @Test
     public void testConfigForPropertySorting() throws Exception