Cách tạo luồng Java 8 từ trình lặp?

Question

Có thể tạo một luồng từ một Iterator, trong đó chuỗi các đối tượng giống với chuỗi được tạo ra bằng cách gọi phương thức next() của trình lặp lặp lại không? Trường hợp cụ thể tôi đang nghĩ đến các mối quan tâm về việc sử dụng trình lặp được trả về bởi TreeSet.descendingIterator(), nhưng tôi có thể tưởng tượng các trường hợp khác trong đó một trình lặp, nhưng không phải là bộ sưu tập mà nó tham chiếu, có sẵn. Ví dụ, đối với một TreeSet<T> tset chúng ta có thể viết tset.stream()... và nhận được một luồng các đối tượng trong tập hợp đó, theo thứ tự sắp xếp của bộ, nhưng nếu chúng ta muốn chúng theo thứ tự khác, chẳng hạn như có sẵn thông qua việc sử dụng descendingIterator() thì sao? Tôi đang tưởng tượng một cái gì đó như tset.descendingIterator().stream()... hoặc stream(tset.descendingIterator())..., mặc dù cả hai biểu mẫu này đều không hợp lệ.

Answer 1

Ví dụ cụ thể của NavigableSet.descendingIterator(), tôi nghĩ cách đơn giản nhất là sử dụng NavigableSet.descendingSet() thay thế.

Nhưng với bạn có lẽ quan tâm trong trường hợp tổng quát hơn, sau đây dường như làm việc:

import java.util.Iterator; 
import java.util.Spliterator; 
import java.util.Spliterators; 
import java.util.TreeSet; 
import java.util.stream.Stream; 
import java.util.stream.StreamSupport; 

public class Streams { 
    public static void main(String... args) { 
     TreeSet<String> set = new TreeSet<>(); 
     set.add("C"); 
     set.add("A"); 
     set.add("B"); 

     Iterator<String> iterator = set.descendingIterator(); 

     int characteristics = Spliterator.DISTINCT | Spliterator.SORTED | Spliterator.ORDERED; 
     Spliterator<String> spliterator = Spliterators.spliteratorUnknownSize(iterator, characteristics); 

     boolean parallel = false; 
     Stream<String> stream = StreamSupport.stream(spliterator, parallel); 

     stream.forEach(System.out::println); // prints C, then B, then A 
    } 
} 

Tóm lại, bạn phải tạo một Spliterator từ Iterator đầu tiên bằng một trong những phương pháp tĩnh trong Spliterators . Sau đó, bạn có thể tạo một Stream bằng cách sử dụng các phương pháp tĩnh trong StreamSupport.

Tôi chưa có nhiều kinh nghiệm với việc tạo Trình tách và Luồng bằng tay, vì vậy tôi không thể thực sự nhận xét về những đặc tính nên là gì hoặc chúng sẽ có tác dụng gì. Trong ví dụ đơn giản đặc biệt này, dường như không có vấn đề gì nếu tôi xác định các đặc tính như trên, hoặc tôi đặt nó thành 0 (tức là không có đặc điểm). Ngoài ra còn có một phương pháp trong Spliterators để tạo ra một Spliterator với ước tính kích thước ban đầu - Tôi giả sử trong ví dụ cụ thể này bạn có thể sử dụng set.size(), nhưng nếu bạn muốn xử lý Iterator tùy ý tôi đoán điều này sẽ không xảy ra. Một lần nữa, tôi không hoàn toàn chắc chắn về hiệu quả của nó trên hiệu suất.

Answer 2

static <T> Stream<T> iteratorToFiniteStream(final Iterator<T> iterator) { 
    return StreamSupport.stream(Spliterators.spliteratorUnknownSize(iterator, 0), false); 
} 

static <T> Stream<T> iteratorToInfiniteStream(final Iterator<T> iterator) { 
    return Stream.generate(iterator::next); 
} 

Answer 3

này không tạo ra một dòng, nhưng Iterator cũng có một phương pháp gọi là forEachRemaining:

someIterator.forEachRemaining(System.out::println); 
someIterator.forEachRemaining(s -> s.doSomething()); 
//etc. 

Đối số bạn vượt qua trong là một Consumer đó là điều tương tự để bạn vượt qua Stream::forEach.

Here are the docs cho phương pháp đó. lưu ý rằng bạn không thể tiếp tục "chuỗi" như bạn có thể với luồng. Nhưng tôi vẫn thấy điều này hữu ích một vài lần tôi đã muốn một Stream từ Iterator.