Utwórz strumień Java 8 z ArrayNode

Question

Czy można utworzyć strumień z com.fasterxml.jackson.databind.node.ArrayNode?
Próbowałem:

ArrayNode files = (ArrayNode) json.get("files"); 
Stream<JsonNode> stream = Stream.of(files); 

Ale to faktycznie dają strumień z jednego elementu, początkowej przedmiotu ArrayNode.
Prawidłowy wynik powinien być Stream<JsonNode>, czy mogę to osiągnąć?

Answer 1

ArrayNode implementuje Iterable. Iterable ma metodę spliterator(). Można create a sequential Stream from a Spliterator użyciu

StreamSupport.stream(spliterator, false) 

Answer 2

ArrayNode # elementy zwraca iterator na to elementy można używać, aby stworzyć strumień (wykorzystując StreamSupport). StreamSupport wymaga Spliteratora, a do stworzenia Spliteratora z Iteratora możesz użyć klasy Spliterators.

ArrayNode files = (ArrayNode) json.get("files"); 
    Stream<JsonNode> elementStream = StreamSupport.stream(Spliterators 
        .spliteratorUnknownSize(files.elements(), 
         Spliterator.ORDERED),false); 

cyclops-streams ma klasę StreamUtils ma statyczną metodę, która sprawia, że ​​ten nieco czystsze (jestem autorem).

ArrayNode files = (ArrayNode) json.get("files"); 
Stream<JsonNode> elementStream = StreamUtils.stream(files.elements()); 

Uwzględniając @JB odpowiedź Nizet że ArrayNode jest iterable z StreamUtils można przekazać w ArrayNode i dostać z powrotem bezpośrednio Stream.

Stream<JsonNode> elementStream = StreamUtils.stream((ArrayNode) json.get("files")); 

Answer 3

ArrayNode klasa zapewnia swobodny dostęp: można dostać size() oraz element o indeksie (używając get(index)). To wszystko, czego potrzebujesz, aby stworzyć dobrą strumieniowe:

Stream<JsonNode> nodes = IntStream.range(0, files.size()).mapToObj(files::get); 

Zauważ, że to rozwiązanie jest lepsze niż przy użyciu domyślnego spliterator (sugerowane przez innych Główni odpowiadający), gdyż może to dobrze podzielone i informuje o wielkości odpowiednio. Nawet jeśli nie dbasz o przetwarzanie równoległe, niektóre operacje, takie jak toArray(), będą działać efektywniej, ponieważ znajomość rozmiaru z góry pomoże przydzielić tablicę o odpowiednim rozmiarze.