如何创建org.reactivestreams。从java.io.InputStream发布<ByteBuffer>?

如何 org.reactivestreams.Publisher<ByteBuffer> 由a创建 java.io.InputStream ?

上下文:我正在使用awssdk创建一个 AsyncRequestBody ,我有一个InputStream,因此正在尝试使用 AsyncRequestBody.fromPublisher 方法,因为其他“from”方法都不匹配。

有 a similar question 但根据答案,这个问题的真正问题似乎与蒙古有关;我的问题是一个更广泛的反应流问题。

提前感谢您的考虑和回复。