- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我正在使用 Akka HTTP,并且我有一个查询 URL 的客户端。代码是这样的:
def f1(): Future[HttpResponse] = { ... }
我想编写一个 f2
函数,该函数接受 HttpRespons
e,但将其转换为 Future[String]
,其中 String
是消息的主体。所以我在寻找:
def f2(): Future[String] = f1().map(...)
我无法将其转换为正常工作。
问题 #1:我认为这更像是一个基本的 Scala 问题。我将如何转换这个 future ?我能得到的最好的是:
def f2:Future[String] = {
f1().map (_.entity.toStrict(300.milli).map(_.data.utf8String))
}
这是行不通的,因为我最终得到了一个 Future[Future[String]]
问题 #2:根据我的理解,这是一个 akka-http 问题。
f1().map(_.toStrict())
是否暗示 f1().map(_.entity.toStrict())
?
如果是这样,我如何才能访问该实体而不必对其调用 toStrict?
最佳答案
//1. 你可以使用 for comprehension (with Option[Option[T]], Future[Future[T]], Try[Try[T]) or flatMap or .map { _ pipeTo self } (if在 Actor 中)。
val httpResponseF: Future[HttpResponse] = Future.successful(HttpResponse(entity = HttpEntity.Strict(ContentTypes.`text/plain(UTF-8)`, data = ByteString("test"))))
val res: Future[String] = for {
httpResponse <- httpResponseF
entity <- httpResponse.entity.toStrict(300.milli)
} yield {
entity match {
case HttpEntity.Strict(contentType, data) => data.utf8String
}
}
assert(Await.result(res, 1.second) == "test")
//2. 他们看起来和我不一样:akka.http.scaladsl.model.HttpResponse
def
toStrict(timeout: FiniteDuration)(implicit ec: ExecutionContext, fm: Materializer): Future[Self]
对比
//akka.http.javadsl.model.ResponseEntity
def
toStrict(timeoutMillis: Long, materializer: Materializer): CompletionStage[HttpEntity.Strict]
一个使用隐式。
这是获取字符串作为 http 客户端的一种方法。
object Example {
import scala.concurrent.Future
import akka.actor.ActorSystem
import akka.http.scaladsl.Http
import akka.stream.ActorMaterializer
import akka.stream.scaladsl.Sink
import akka.stream.scaladsl.Source
import akka.http.scaladsl.unmarshalling._
import akka.http.scaladsl.model._
import scala.util.{Try,Success,Failure}
implicit val system = ActorSystem()
implicit val materializer = ActorMaterializer()
implicit val ec = system.dispatcher
// construct a pool client flow with context type `Int`
val poolClientFlow = Http().cachedHostConnectionPool[Int]("akka.io")
val responseFuture: Future[String] =
Source.single(HttpRequest(uri = "/") -> 1)
.via(poolClientFlow)
.mapAsync(1) {
case (Success(response), i) => Unmarshal(response.entity).to[String]
case (Failure(e), i) => Future.failed(e)
}
.runWith(Sink.head)
}
如果有更具体的类型(如果使用 Scala 则更惯用),您尝试解码为而不是字符串,您可以使用此 Json 作为模板创建自定义 Unmarshaller:https://github.com/hseeberger/akka-http-json/blob/master/akka-http-json4s/src/main/scala/de/heikoseeberger/akkahttpjson4s/Json4sSupport.scala否则有 Unmarshallers.String http://doc.akka.io/docs/akka/2.4.3/java/http/routing-dsl/marshalling.html#Unmarshalling
有时检查 Spray 邮件列表和文档会有所帮助,因为它的活跃时间更长,即使在 akka-http 中有一种新方法可以做到这一点,它至少提供了一个起点。
关于scala - Akka-http 并将 Future[HttpResponse] 转换为 Future[String],我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/36442165/
如果您想使用 String.Concat() 连接 5 个或更多字符串,则它会使用 Concat(String[])。 为什么不一直使用 Concat(String[]) 而不再需要 Concat(S
今天在使用 String 时,我遇到了一种我以前不知道的行为。我无法理解内部发生的事情。 public String returnVal(){ return "5";
似乎在我所看到的任何地方,都有一些过时的版本,这些版本不再起作用。 我的问题似乎很简单。我有一个Java类,它映射到derby数据库。我正在使用注释,并且已经成功地在数据库中创建了所有其他表,但是在这
一、string::size_type() 在C++标准库类型 string ,在调用size函数求解string 对象时,返回值为size_type类型,一种类似于unsigned类型的int 数据
我正在尝试将数据保存到我的 plist 文件中,其中包含字符串数组的定义。我的plist - enter image description here 我将数据写入 plist 的代码是 -- let
我有一个带有键/值对的 JavaScript 对象,其中值是字符串数组: var errors = { "Message": ["Error #1", "Error #2"], "Em
例如,为了使用相同的函数迭代 List 和 List> ,我可以编写如下内容: import java.util.*; public class Test{ public static voi
第一个Dictionary就像 Dictionary ParentDict = new Dictionary(); ParentDict.Add("A_1", "1")
这是我的 jsp 文件: 我遇到了错误 The method replace(String, String, String) in the type Functions is not appl
我需要一些帮助。我有一个方法应该输出一个包含列表内容的 txt 文件(每行中的每个项目)。列表项是字符串数组。问题是,当我调用 string.Join 时,它返回文字字符串 "System.Strin
一位同事告诉我,使用以下方法: string url = "SomeURL"; string ext = "SomeExt"; string sub = "SomeSub"; string s
给定类: public class CategoryValuePair { String category; String value; } 还有一个方法: public
我正在尝试合并 Stream>>对象与所有 Streams 中的键一起映射到单个映射中. 例如, final Map someObject; final List>> list = someObjec
在这里使用 IDictionary 的值(value)是什么? 最佳答案 使用接口(interface)的值(value)始终相同:切换到另一个后端实现时,您不必更改客户端代码。 请考虑稍后分析您的代
我可以知道这两个字典声明之间的区别吗? var places = [String: String]() var places = [Dictionary()] 为什么当我尝试以这种方式附加声明时,只有
在 .NET 4.0 及更高版本中存在 string.IsNullOrWhiteSpace(string) 时,在检查字符串时使用 string.IsNullOrEmpty(string) 是否被视为
这个名字背后的原因是什么? SS64在 PowerShell 中解释此处的字符串如下: A here string is a single-quoted or double-quoted string
我打算离开 this 文章,尝试编写一个接受字符串和 &str 的函数,但我遇到了问题。我有以下功能: pub fn new(t_num: S) -> BigNum where S: Into {
我有一个结构为 [String: [String: String]] 的多维数组。我可以使用 for 循环到达 [String: String] 位,但我不知道如何访问主键(这个位 [String:
我正在尝试使用 sarama(管理员模式)创建主题。没有 ConfigEntries 工作正常。但我需要定义一些配置。 我设置了主题配置(这里发生了错误): tConfigs := map[s
我是一名优秀的程序员,十分优秀!