java.util.stream.Streamを<String>にjava.io.Readerに変換する

Question

私のアプリケーションの一部にInputStreamが与えられ、これを処理して別のInputStreamを生成したいとします。

try (
    final BufferedReader inputReader = new BufferedReader(new InputStreamReader(inputStream, UTF_8), BUFFER_SIZE); 
    final Stream<String> resultLineStream = inputReader.lines().map(lineProcessor::processLine); 
    final InputStream resultStream = new ReaderInputStream(new StringStreamReader(resultLineStream), UTF_8); 
) { 
    s3Client.putObject(targetBucket, s3File, resultStream, new ObjectMetadata()); 
} catch (IOException e) { 
    throw new RuntimeException("Exception", e); 
} 

私は簡単に私の処理機能をマッピングすることができ、その上にストリームに新しいJava 8 BufferedReader.lines()を使用しています。

まだ唯一欠けているのは、StreamStreamReader（）です。これは、ストリームをReaderに変換することになっています。このストリームから、Apacheのcommons-io：ReaderInputStreamはInputStreamを再度作成できます。 （読者や背中への迂回は、エンコードと改行に対処するために合理的なようです。）

は非常に明確にするために、上記のコードはそう

public class StringStreamReader extends Reader { 
    public StringStreamReader(Stream<String> stringStream) { ... } 

    @Overwrite 
    public int read(char cbuf[], int off, int len) throws IOException { ... } 

    // possibly overwrite other methods to avoid bad performance or high resource-consumption 
} 

を前提とし、このようなStringStreamReaderクラスを提供しています任意のライブラリはありますか？またはこれは、カスタムReaderまたはInputStreamサブクラスを実装せずに上記のアプリケーションコードを記述する別の方法ですか？

Answer 1

あなたはそのような何かすることができます

PipedWriter writer = new PipedWriter(); 
    PipedReader reader = new PipedReader(); 
    reader.connect(writer); 

    strings.stream().forEach(string -> { 
     try { 
      writer.write(string); 
      writer.write("\n"); 
     } catch (Exception e) { 
      e.printStackTrace(); 
     } 
    }); 

をしかし、私はあなたが怠惰な処理のいくつかのフォームをしたいと思います。ストリームAPIは実際には役に立ちません。専用のスレッド+バッファを必要とします。