Akış halihazırda çalışmış veya kapatılmış - Java 8

Question

Neden bir sonraki özel durumum var? bunu düzeltmek için kodunu değiştirmek nasıl

Exception in thread "main" java.lang.IllegalStateException: stream has already been operated upon or closed 
at java.util.stream.AbstractPipeline.<init>(AbstractPipeline.java:203)... 

com.search.offer.OffersSelector.isGood (OffersSelector.java:23) ?

Stream<String> titleExclusions = ResourceUtility.contentToUtf8TreeSet("+.txt"). 
     stream().filter(item -> item.length() == 0).collect(Collectors.toSet()).stream(); 
//... 
titleExclusions.filter(tittle::contains).collect(Collectors.toSet()).size() == 0;//line 23 

Answer 1

Akımlar üzerinde birden çok kez çalışamazsınız, bu nedenle birden çok kez kullanabileceğiniz için Koleksiyonlar'ı kullanmaktan daha iyidir.

Set<String> titleExclusions = ResourceUtility.contentToUtf8TreeSet("+.txt") 
              .stream() 
              .filter(item -> !item.isEmpty()) 
              .collect(Collectors.toSet()); 
// uses titleExclusions 
boolean noMatches = titleExclusions.stream() 
            .noneMatch(tittle::contains); 
// uses titleExclusions again. 

Not: Ben yerine boş olanlar setleri kaynak dosyadan olmayan boş satırları istediğini farz. filter, atılandan ziyade nelerin saklı tutulduğunu Predicate alır.

İkinci ifadeyi sadeleştirdiğiniz için teşekkür ederiz @Holger.