发现：akka.http.scaladsl.server.StandardRoute [错误] 需要：scala.util.Try

Question

我是 Scala 和 akka 的新手，我正在尝试发布端点。发生以下编译错误。

 found: akka.http.scaladsl.server.StandardRoute
 [error]  required: scala.util.Try[Option[com.activegrid.entities.AuthSettings]] => (akka.http.scaladsl.server.RequestContext => scala.concurrent.Future[akka.http.scaladsl.server.RouteResult])

案例class

case class AuthSettings(authType:String,authLevel:String,scope:String);

Enpoint

pathPrefix("config") {
       path("settings"/"auth") {
         post {
           entity(as[AuthSettings]) { authSettings =>
             val save: Future[AuthSettings] = persistance.persistAuthSettings(authSettings)
             onComplete(save) {
               complete("To insert app settings")
             }
           }
         }
       }

persistAuthSettings 定义

def persistAuthSettings(authSettings: AuthSettings) : Future[AuthSettings] = Future {
    //Neo4j Operations
    authSettings;

}

我的代码出了什么问题？

Answer 1

onComplete 从 future 中提取值，并需要一个对该值进行操作的函数：

onComplete(save) { appSettings =>
  complete("To insert app settings")
}

发现：akka.http.scaladsl.server.StandardRoute [错误] 需要：scala.util.Try

found : akka.http.scaladsl.server.StandardRoute [error] required: scala.util.Try

scala

akka-stream

akka-http