将 OutputStream 转换为 PipedOutputstream

Question

在 Java 中，函数 A 中有一些现有代码返回一个 OutputStream，但我希望它返回一个 PipedOutputStream，我可以将它与 PipedInputStream 一起使用，如下所示：

this.inputStream = new PipedInputStream(this.outputStream);

将 OutputStream 转换为 PipedInputStream 是否有效，还是我需要从一个全新的 PipedOutputStream 开始并在那里重复所有逻辑？

更多代码：

我的 PipedInputStream 将像这样将数据传输到 s3：

tm.upload(bucketName, objectKey, this.inputStream, objectMetadata);

（tm 是 TransferManager）

并且 PipedOutputStream 将与写入文件的 Writer 一起使用。

OutputStream out = (encryptionKeyId != null) ?
                    pgpService.buildPgpOutputStream(this.outputStream, encryptionKeyId) :
                    this.outputStream;
            return toBufferedWriter(out);

所以在上面的开关中，当out 是this.outputStream; 时，它工作正常。因为它是 PipedOutputStream。但是pgpService.buildPgpOutputStream(this.outputStream, encryptionKeyId) 返回的是一个 OutputStream，而不是 Piped 的，所以不知道该怎么做。

Answer 1

你不需要做任何事情。

您构建的bufferedWriter 最终会写入this.outputStream，这是您的管道输出流。您不需要对其进行强制转换或对其进行任何操作 - 您已经在类的实例变量中引用了管道的两端。我假设您的代码如下所示。

this.outputStream = new PipedOutputStream();
this.inputStream = new PipedInputStream(this.outputStream);
OutputStream out = (encryptionKeyId != null) ?
                    pgpService.buildPgpOutputStream(this.outputStream, encryptionKeyId) :
                    this.outputStream;
return toBufferedWriter(out);