akka-http

1热度

1回答

我有this应用程序使用Akka Streams和ReactiveMongo。没有用户定义的演员。该应用程序从main方法启动。问题是在main方法完成后JVM将继续运行。这是我现在在做什么： val g = (file: String) => RunnableGraph.fromGraph(GraphDSL.create(Sink.ignore) { implicit builder

0热度

1回答

什么是路由连接的标识元素或中性元素？

波浪号~用于连接Akka HTTP中的Route。可能还有其他应用程序，但我的动机是希望使用~运算符将一组路线变成一条路线。要做到这一点，这将有可能采取???的地方在下面的foldLeft例如“零”的元素有用： val routes: Seq[Route] = ... val route = routes.foldLeft[Route](???)(_ ~ _) 所需的零将是~单位元，这将是

0热度

1回答

Akka HTTP只响应4个请求

我写了一个简单的演员，下载一个网页并将此页面的主体发送给其发件人。我使用Akka HTTP来构建HTTP请求并处理HTTP响应。这里是我的代码： class Downloader(uri: String) extends Actor { import akka.pattern.pipe import context.dispatcher final implici

2热度

1回答

为什么指令中的`map`有时将结果包装在一个元组中？

以下example from the the Akka HTTP docucumentation表明您可以使用Directives的map方法很像你希望改造自己的价值。 val textParam: Directive1[String] = parameter("text".as[String]) val lengthDirective: Directive1[Int] =

2热度

1回答

如何在带有超时的单独调度程序上运行Akka Streams图？

这个问题是基于我做的一个宠物项目和这个SO线程。在Akka HTTP路由定义中，我开始了一个长期运行的过程，当然我想这样做而不会阻止用户。我可以用下面的代码片段来实现这一目标： blocking-io-dispatcher { type = Dispatcher executor = "thread-pool-executor" thread-pool-executo

0热度

1回答

测试完成无限流的akka-http路由

我有一个akka-http路由，它返回一个包含无限实体流的Source。我如何测试使用路由测试工具包？我想检查流的前n个元素，但是我已经看了一下testkit代码，看起来好像没有直接的方式来访问响应中的Source。它总是被转换为ByteString的序列，在我的情况下，这只是导致TimeoutException，因为流不会终止。作为参考，这个问题可以用路线转载看起来像这样： case clas

2热度

1回答

编组站在阿卡HTTP

在this链接，文档使用instanceof来封送对象为JSON，如下图所示： val route = get { completeWith(instanceOf[Person]) { completionFunction => findPerson(completionFunction) } } 然而，当我尝试使用相同的我得到的错误“unable to resolve symbo

0热度

1回答

如何上传文件阿卡HTTP 10文件大小> 100 KB

我从邮递员化妆要求上传文件到另一个服务akkka HTTP服务器（10.0版）（它连接的Amazon S3）使用的图像文件（图像大小= 275 KB），并且它具有异常 akka.stream.impl.SubscriptionTimeoutException：子流源还没有被实例化在5000毫秒使用图像尺寸< 20 KB，它的工作为什么？这是我的代码 (post & entity

0热度

1回答

在akka-http如何从路由获取List [HttpRequest]？

在akka-http因为以下 case HttpRequest(GET, Uri.Path("/ping"), _, _, _) => HttpResponse(entity = "PONG!") 也可以写成 val route: Route = path("ping") { complete("PONG!") } 是否有可能得到Seq[Http

3热度

2回答

Akka Http - 如何解开ResponseEntity到CustomClass？

我正在使用Akka Http向第三方API发出请求。答案是“application/json”，我想使用Akka Http将它们转换为自定义案例类。我愿做这样的事情： val request = RequestBuilding.Get("https://service.com/v1/api/items") val response : Future[ItemsResponse] = http.