代码之家 › 专栏 › 技术社区 › Igor Yudnikov

Akka HTTP route post实体字符串,包含Future

akka-http future akka routes scala

Igor Yudnikov · 技术社区 · 7 年前

我有一个Akka HTTP守护程序。假设我想接收一些JSON格式的客户端数据,并将其异步保存到数据库中。我在一家邮局写了一条路线:

path("product") {
  entity(as[String]) { json =>
    val saveFuture: Future[Unit] = Serialization.read[Product](json).save()
    complete("")
  }
}

我发现了 complete 可以放入 onSuccess 声明如下:

path("success") {
  onSuccess(Future { "Ok" }) { extraction =>
    complete(extraction)
  }
}

但我不明白如何把它们粘在一起。

1 回复 | 直到 7 年前

Jeffrey Chung 7 年前

可以嵌套指令:

path("product") {
  entity(as[String]) { json =>
    val saveFuture: Future[Unit] = Serialization.read[Product](json).save()
    onSuccess(saveFuture) {
      complete("json was saved")
    }
  }
}

推荐文章

Kackao · 获取std::future的运行时间::wait\u for

6 年前

JRR · 出现错误时如何停止并行循环

6 年前

ozgeneral · 在R中使用异步未来追加全局表

6 年前

Joshua Esolk · 为什么在Akka Dispatcher上启动Futures时,Futures中的Futures会按顺序运行

6 年前

Mandroid · Java未来异步?

6 年前

opensourcegeek · 如何从流本身中取消无限流?

6 年前

Lingxi · 为什么没有std::future::try\u wait()?

6 年前

BorÈ Nicolae · 可调用类中的并发修改异常

6 年前

G.Saleh · scala Future运行顺序作业

6 年前

KOGI · 如何取消/中止Dart中的区域?

7 年前