Bagaimana cara mengubah iterator menjadi stream?

Saya mencari cara ringkas untuk mengkonversi Iterator ke Streamatau lebih khusus untuk "melihat" iterator sebagai aliran.

Untuk alasan kinerja, saya ingin menghindari salinan iterator dalam daftar baru:

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

Berdasarkan beberapa saran dalam komentar, saya juga mencoba menggunakan 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);
}

Namun, saya mendapatkan NoSuchElementException(karena tidak ada doa 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)

Saya telah melihat StreamSupportdan Collectionstetapi saya tidak menemukan apa pun.

Salah satu caranya adalah dengan membuat Spliterator dari Iterator dan menggunakannya sebagai dasar untuk streaming Anda:

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

Alternatif yang mungkin lebih mudah dibaca adalah menggunakan Iterable - dan membuat Iterable dari Iterator sangat mudah dengan lambdas karena Iterable adalah antarmuka fungsional:

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

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

Sejak versi 21, perpustakaan Guava menyediakan Streams.stream(iterator)

Ia melakukan apa yang ditunjukkan oleh jawaban assylias .

Saran bagus! Inilah pendapat saya yang dapat digunakan kembali:

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);
    }
}

Dan penggunaan (pastikan untuk mengimpor asStream secara statis):

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

Ini dimungkinkan di Java 9.

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

Buat Spliteratordari Iteratormenggunakan Spliteratorskelas berisi lebih dari satu fungsi untuk membuat spliterator, misalnya di sini saya menggunakan spliteratorUnknownSizeyang mendapatkan iterator sebagai parameter, lalu buat Streaming menggunakanStreamSupport

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

import com.google.common.collect.Streams;

dan gunakan Streams.stream(iterator):

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

Cara lain untuk melakukan ini di Java 9+ menggunakan Stream :: iterate (T, Predicate, UnaryOperator) :

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

Menggunakan Collections.list(iterator).stream()...