Comment convertir un itérateur en flux?

Je cherche un moyen concis de convertir un Iteratoren Streamou plus spécifiquement de "visualiser" l'itérateur comme un flux.

Pour des raisons de performances, je voudrais éviter une copie de l'itérateur dans une nouvelle liste:

Iterator<String> sourceIterator = Arrays.asList("A", "B", "C").iterator();
Collection<String> copyList = new ArrayList<String>();
sourceIterator.forEachRemaining(copyList::add);
Stream<String> targetStream = copyList.stream();

Sur la base des quelques suggestions dans les commentaires, j'ai également essayé d'utiliser Stream.generate:

public static void main(String[] args) throws Exception {
    Iterator<String> sourceIterator = Arrays.asList("A", "B", "C").iterator();
    Stream<String> targetStream = Stream.generate(sourceIterator::next);
    targetStream.forEach(System.out::println);
}

Cependant, je reçois un NoSuchElementException(car il n'y a pas d'invocation de hasNext)

Exception in thread "main" java.util.NoSuchElementException
    at java.util.AbstractList$Itr.next(AbstractList.java:364)
    at Main$$Lambda$1/1175962212.get(Unknown Source)
    at java.util.stream.StreamSpliterators$InfiniteSupplyingSpliterator$OfRef.tryAdvance(StreamSpliterators.java:1351)
    at java.util.Spliterator.forEachRemaining(Spliterator.java:326)
    at java.util.stream.ReferencePipeline$Head.forEach(ReferencePipeline.java:580)
    at Main.main(Main.java:20)

J'ai regardé StreamSupportet Collectionsje n'ai rien trouvé.

Une façon consiste à créer un séparateur à partir de l'itérateur et à l'utiliser comme base pour votre flux:

Iterator<String> sourceIterator = Arrays.asList("A", "B", "C").iterator();
Stream<String> targetStream = StreamSupport.stream(
          Spliterators.spliteratorUnknownSize(sourceIterator, Spliterator.ORDERED),
          false);

Une alternative qui est peut-être plus lisible est d'utiliser un Iterable - et créer un Iterable à partir d'un Iterator est très facile avec lambdas car Iterable est une interface fonctionnelle:

Iterator<String> sourceIterator = Arrays.asList("A", "B", "C").iterator();

Iterable<String> iterable = () -> sourceIterator;
Stream<String> targetStream = StreamSupport.stream(iterable.spliterator(), false);

Depuis la version 21, la bibliothèque Guava fournit Streams.stream(iterator)

Il fait ce que @ assylias l » montre de réponse .

Grande suggestion! Voici ma version réutilisable:

public class StreamUtils {

    public static <T> Stream<T> asStream(Iterator<T> sourceIterator) {
        return asStream(sourceIterator, false);
    }

    public static <T> Stream<T> asStream(Iterator<T> sourceIterator, boolean parallel) {
        Iterable<T> iterable = () -> sourceIterator;
        return StreamSupport.stream(iterable.spliterator(), parallel);
    }
}

Et l'utilisation (assurez-vous d'importer statiquement asStream):

List<String> aPrefixedStrings = asStream(sourceIterator)
                .filter(t -> t.startsWith("A"))
                .collect(toList());

C'est possible dans Java 9.

Stream.generate(() -> null)
    .takeWhile(x -> iterator.hasNext())
    .map(n -> iterator.next())
    .forEach(System.out::println);

Créer Spliteratorà Iteratorpartir de la Spliteratorsclasse contient plus d'une fonction pour créer un séparateur, par exemple ici, j'utilise spliteratorUnknownSizequi obtient l'itérateur comme paramètre, puis créer un flux à l'aideStreamSupport

Spliterator<Model> spliterator = Spliterators.spliteratorUnknownSize(
        iterator, Spliterator.NONNULL);
Stream<Model> stream = StreamSupport.stream(spliterator, false);

import com.google.common.collect.Streams;

et utiliser Streams.stream(iterator):

Streams.stream(iterator)
       .map(v-> function(v))
       .collect(Collectors.toList());

Une autre façon de le faire sur Java 9+ en utilisant Stream :: iterate (T, Predicate, UnaryOperator) :

Stream.iterate(iterator, Iterator::hasNext, UnaryOperator.identity())
        .map(Iterator::next)
        .forEach(System.out::println);

Utilisation Collections.list(iterator).stream()...