Estou procurando uma maneira concisa de converter um Iterator
para um Stream
ou mais especificamente para "visualizar" o iterador como um fluxo.
Por motivos de desempenho, gostaria de evitar uma cópia do iterador em uma nova lista:
Iterator<String> sourceIterator = Arrays.asList("A", "B", "C").iterator();
Collection<String> copyList = new ArrayList<String>();
sourceIterator.forEachRemaining(copyList::add);
Stream<String> targetStream = copyList.stream();
Com base nas sugestões apresentadas nos comentários, também tentei usar 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);
}
No entanto, recebo um NoSuchElementException
(já que não há invocação 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)
Eu olhei StreamSupport
e Collections
não encontrei nada.
Stream.generate(iterator::next)
funciona?Respostas:
Uma maneira é criar um Spliterator a partir do Iterator e usá-lo como base para o seu fluxo:
Uma alternativa que talvez seja mais legível é usar um Iterable - e criar um Iterable a partir de um Iterator é muito fácil com lambdas porque o Iterable é uma interface funcional:
fonte
sourceIterator.next()
antes de usar o fluxo e verá o efeito (o primeiro item não será visto pelo fluxo).Iterable<String> iterable = () -> sourceIterator;
. Eu tenho que admitir que levei algum tempo para entender.Iterable<T>
é umFunctionalInterface
que possui apenas um método abstratoiterator()
. O mesmo() -> sourceIterator
ocorre com uma expressão lambda que instancia umaIterable
instância como uma implementação anônima.() -> sourceIterator;
é uma forma abreviada denew Iterable<>() { @Override public Iterator<String> iterator() { return sourceIterator; } }
Desde a versão 21, a biblioteca Guava fornece
Streams.stream(iterator)
Ele faz o que a resposta de @ assylias mostra .
fonte
Ótima sugestão! Aqui está a minha opinião reutilizável:
E uso (certifique-se de importar estaticamente comoStream):
fonte
Isso é possível no Java 9.
fonte
.parallel()
fluxos. Elas também parecem um pouco mais lentas do que as repetidasSpliterator
, mesmo para uso seqüencial.parallel
possa ser descolada, a simplicidade é incrível.A classe Create
Spliterator
fromIterator
usingSpliterators
contém mais de uma função para criar spliterator, por exemplo, aqui estou usando ospliteratorUnknownSize
que está obtendo o iterador como parâmetro e, em seguida, crie Stream usandoStreamSupport
fonte
e use
Streams.stream(iterator)
:fonte
Outra maneira de fazer isso no Java 9+ usando Stream :: iterate (T, Predicate, UnaryOperator) :
fonte
Usar
Collections.list(iterator).stream()...
fonte