将 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() 到流，我可以轻松地将我的处理函数映射到流上。

唯一还缺少的是 class StringStreamReader()，它将我的 Stream 转换为 Reader，Apache commons-io:Reader InputStream 可以重新创建一个 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 class？或者还有另一种方法可以在不实现自定义 Reader 或 InputStream subclass?

的情况下编写上面的应用程序代码

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 在这种情况下并没有真正的帮助，你需要一个专用的线程 + 一些缓冲区来做到这一点。

将 java.util.stream.Stream<String> 转换为 java.io.Reader

converting a java.util.stream.Stream<String> into a java.io.Reader

java

guava