akka-stream 相关问题

我正在尝试使用 Akka Streams 实现分页。目前我有 case class SomeObject(id:Long, next_page:Option[Map[String,String]]) def chainRequests(uri: Uri): Future[Option[(Uri, T)]] =...

scala akka akka-stream akka-http

回答 2 投票 0

在流中链接 Akka-http-client 请求

我想使用 akka-http-client 作为流来链接 http 请求。链中的每个 http 请求都取决于先前请求的成功/响应，并使用它来构造新请求。如果有...

scala akka-stream akka-http

回答 2 投票 0

处理分页结果的 Akka Streams 流程未完成

我想实现一个流程来处理分页结果（例如，底层服务返回一些结果，但也表明通过发出另一个请求可以获取更多结果，传入例如...

scala pagination akka akka-stream

回答 3 投票 0

IllegalStateException - Sink.asPublisher 仅支持一个订阅 - 使用 WebSockets 时

在生产中，我们的应用程序生成了以下堆栈跟踪。这里没有我们自己的代码——没什么可继续的。了解 akka-stream 库的人可以解释一下：什么是

playframework akka-stream

回答 1 投票 0

基于URL或本地文件限制流

我有一个 akka http API，用户可以将 S3 URL 发送到服务器。然后，服务器从 AWS 服务器启动流并对源执行后续操作。不过我想验证

scala akka akka-stream akka-http

回答 1 投票 0

Akka Streams RestartSource.onFailuresWithBackoff 停止条件

如果出现异常，我正在使用 RestartSource.onFailuresWithBackoff 重新启动源，但如果收到某种异常类型，我想停止（取消）重新启动。例如：

scala akka-stream

回答 2 投票 0

Akka Streams flatMapConcat 在创建新源时停止以前的源

我有一个用例，我有一个提供服务“地址”的源。然后我想将该地址映射到从该服务传输数据的源。现在，万一我会得到......

akka akka-stream

回答 1 投票 0

如何捕获最大RestartSource后alpakka kafka源流失败

如何捕获最大重启次数后RestartSource的错误？我想在源失败最大次数后做一些事情。我可以看到源正在重新启动...

apache-kafka akka akka-stream alpakka akka-kafka

回答 1 投票 0

获取重载方法〜>使用替代方案Akka广播

我正在尝试将传入的 Source[ByteString, Any] 广播到 2 个不同的流，然后扇入（zip）输出。但是我收到错误“重载方法 ~> 使用替代方案”。瓦尔

scala akka akka-stream

回答 1 投票 0

使用 ScalaFX 监控 Akka 流源

我要解决的是以下情况：给定一个无限运行的 Akka Stream，我希望能够监视流的某些点。我能想到的最好的办法就是把这些乱七八糟的东西送到哪里......

scala javafx akka akka-stream scalafx

回答 1 投票 0

限制 Akka 流中的源滴答频率并始终对最新消息采取行动

以下是问题的背景：有一个 Source，它不断地滴答作响，无法保证滴答的频率我们想要限制源的最大滴答率（例如，我们

scala akka akka-stream

回答 1 投票 0

从流中提取 Source[ByteString, Any] 到 2 个接收器中

我正在尝试将传入的 Source[ByteString, Any] 放入 2 个接收器中并尝试在 akka 流图中复制传入流。我想要“is”作为输入流，但不是 t...

scala akka akka-stream

回答 1 投票 0

akka-stream 相关问题

最新问题