Czy zamknięcie strumienia zamyka źródło BufferedReader?

Question

Od the docs:

Strumienie mają metodę BaseStream.close() i wdrożyć AutoCloseable, ale prawie wszystkie przypadki strumień rzeczywistości nie muszą być zamknięte po użyciu. Zasadniczo, tylko strumienie, których źródłem jest kanał IO (takie jak , jak te zwrócone przez Files.lines (Path, Charset)) będą wymagały zamknięcia. Większość strumieni jest obsługiwana przez kolekcje, tablice lub generujące funkcje , które nie wymagają specjalnego zarządzania zasobami. (Jeśli strumień wymaga zamknięcia, nie może być uznana jako zasób w try-with-zasobów oświadczeniu.)

Kiedy tworzę Stream<String> stosując metodę lines() na BufferedReader jak widać poniżej, nie zamknięcie Stream również zamknąć BufferedReader?

try (Stream<String> lines = new BufferedReader(new InputStreamReader(process.getInputStream())).lines()) { 
    // Do stuff 
} 

// Is the BufferedReader, InputStreamReader and InputStream closed? 

Niektóre naprawdę szybkie testy próbowałem powiedzieć nie (pole z BufferedReaderin nie jest null), ale jestem zdezorientowany przez następnym zdaniu, ponieważ to przykładem jest I/O jak dobrze, dobrze?

Ogólnie, tylko strumienie, których źródłem jest kanał IO (takiego jak te zwrócony przez Files.lines (Ścieżka Charset)) wymaga zamknięcia.

Jeśli nie, muszę zamknąć zarówno instancji, albo zamykając BufferedReader wystarczą?

---

Idealnie, chciałbym zwrócić Stream<String> z jakiejś metody, bez konieczności martwić klienta o czytelników. W tej chwili stworzyłem dekorator Stream, który również zamyka czytnik, ale jest to łatwiejsze, jeśli nie jest to konieczne.

Answer 1

Nie, wygląda na to, że tak nie jest. Ponieważ strumień jest tworzony przy użyciu

return StreamSupport.stream(Spliterators.spliteratorUnknownSize(
      iter, Spliterator.ORDERED | Spliterator.NONNULL), false); 

który nie przechodzi żadnego odniesienia do tej BufferedReader

Answer 2

W swoim pytaniu nie pokazują, jak utworzyć Reader który jest argument new BufferedReader(in). Ale z moich własnych testów nie ma powodu, aby zakładać, że Stream zamyka ten argument.

wykonując następujące czynności należy zamknąć każdy:

import java.io.BufferedReader; 
import java.io.File; 
import java.io.FileInputStream; 
import java.io.InputStreamReader; 
import java.io.Reader; 
import java.util.stream.Stream; 

public class SOPlayground { 

    public static void main(String[] args) throws Exception { 
     try (Reader in = new InputStreamReader(new FileInputStream(new File("/tmp/foo.html"))); 
       BufferedReader reader = new BufferedReader(in); 
       Stream<String> lines = reader.lines()) { 
      lines.forEach(System.out::println); 
     }   
    } 
} 

Answer 3

Jeśli chcesz odroczyć zamknięcie czytnika do dostarczonego Stream trzeba powołać Stream.onClose():

static Stream<String> toStream(BufferedReader br){ 
    return Stream<String> lines = br.lines() 
     .onClose(asUncheckedAutoCloseable(br)); 
} 

static Runnable asUncheckedAutoCloseable(AutoCloseable ac) { 
    return() -> { 
    try { 
     ac.close(); 
    } catch (Exception e) { 
     throw new RuntimeException(e); 
    } 
    } 
}