java - 通过 akka-http 发送输入流

Question

我需要通过 akka http 发送 java.io.InputStream，但我不知道如何做到这一点......我有类似的东西

HttpRequest.POST(buildURL(path, params))
            .withEntity(HttpEntities.create(ContentTypes.APPLICATION_OCTET_STREAM, streamAsSource(inputStream))).withHeaders(m_headers))

并尝试实现streamAsSource...InputStream 甚至可以是一个实体吗？有这方面的例子吗？

Answer 1

StreamConverters.fromInputStream(() -> inputStream))

显然看起来就是答案。