手動でJava 8ストリーム短絡

Question

ストリームを手動で短絡する方法はありますか（findFirstなど）？

例：

ワードサイズとアルファベット順の巨大な辞書を想像：

cat 
... (many more) 
lamp 
mountain 
... (many more) 

だけ準備をし、ラインサイズが4を超えた場合すぐに、最初からリターンをファイルを計算：

read cat, compute cat 
... 
read tree, compute lamp 
read mountain, return 

次のコードは非常に簡潔ですが、利点の中に、ストリームの順序を取らない、それは準備ができて、すべての行にあります。述語がfalseを返したとき

try (Stream<String> lines = Files.lines(Paths.get(DICTIONARY_PATH))) { 
     return lines 
       // filter for words with the correct size 
       .filter(line -> line.length() == 4) 
       // do stuff... 
       .collect(Collectors.toList()); 
} 

Answer 1

回答はLimit a stream by a predicateに基づいて、処理が正常に停止します。うまくいけば、この方法はJava 9で利用できる来る：

private static List<String> getPossibleAnswers(int numberOfChars, char[][] possibleChars) throws IOException { 
    try (Stream<String> lines = Files.lines(Paths.get(DICTIONARY_PATH)) { 
     return takeWhile(lines, line -> line.length() <= numberOfChars) 
       // filter length 
       .filter(line -> line.length() == numberOfChars) 
       // do stuff 
       .collect(Collectors.toList()); 
    } 
} 

static <T> Spliterator<T> takeWhile(Spliterator<T> splitr, Predicate<? super T> predicate) { 
    return new Spliterators.AbstractSpliterator<T>(splitr.estimateSize(), 0) {    boolean stillGoing = true; 

     @Override 
     public boolean tryAdvance(Consumer<? super T> consumer) { 
      if (stillGoing) { 
       boolean hadNext = splitr.tryAdvance(elem -> { 
        if (predicate.test(elem)) { 
         consumer.accept(elem); 
        } else { 
         stillGoing = false; 
        } 
       }); 
       return hadNext && stillGoing; 
      } 
      return false; 
     } 
    }; 
} 

static <T> Stream<T> takeWhile(Stream<T> stream, Predicate<? super T> predicate) { 
    return StreamSupport.stream(takeWhile(stream.spliterator(), predicate), false); 
}