如何将Bytestring转换为Source[Bytestring, Any]

Question

我从Kafka响应式流消费者那里收到一个文件作为字节串;我想用这个字节串作为实体HttpEntity.Default构造一个akka-http请求。HttpEntity。默认要求Source[Bytestring, Any]作为参数之一。

连接两者的最佳方式是什么?

Answer 1

您可以使用Source.single:

HttpEntity.Default(
  ContentTypes.`application/octet-stream`,
  byteString.size,
  Source.single(byteString)
)

也就是说，你真的确定你需要确切的HttpEntity.Default吗?您可以使用HttpEntity.apply(ContentType, ByteString)方法直接从ByteString构造实体:

HttpEntity(ContentTypes.`application/octet-stream`, byteString)

它返回一个HttpEntity.Strict的实例而不是HttpEntity.Default，但是Strict可以用来发送HTTP请求。