java - 将 java.util.stream.Stream 转换为 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() 用于流，我可以轻松地将我的处理函数映射到流上。

唯一仍然缺少的是 StringStreamReader() 类，它应该将我的 Stream 变成一个 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();
        }
    });

但我猜你想要某种形式的惰性处理。 Stream api 在这种情况下并没有真正的帮助，你需要一个专用的线程 + 一些缓冲区来做到这一点。