Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
Akka-Streams 收集数据(Source -> Flow -> Flow (collect) -> Sink)
我对 Scala 和 Akka 完全陌生 我有一个简单的 RunnableFlow Source gt Flow do some transformation gt Sink runForeach 现在我想要这样的东西 Source gt
scala
akkastream
如何在超时的情况下在单独的调度程序上运行 Akka Streams 图?
这个问题是基于我做过的一个宠物项目 这个SO https stackoverflow com questions 34641861 akka http blocking in a future blocks the server 34645
scala
akka
akkastream
akkahttp
Akka Stream Graph 恢复问题
我创建了一个图表来并行化具有相同输入的两个流 这些流产生 Future Option Entity 如果 flowA 失败 我想返回 Future None 但恢复似乎没有被调用 val graph Flow Input Future Op
scala
akka
akkastream
Akka 流如何不断实现?
我在用阿卡流 http doc akka io docs akka stream and http experimental 1 0 scala stream index html在 Scala 中进行轮询AWS SQS https aws
scala
akka
amazonsqs
awssdk
akkastream
Akka Stream 中的 Via/ViaMat/to/toMat
有人能清楚地解释一下这4种方法有什么区别吗 什么时候使用每一种更合适 一般来说 这组方法的名称是什么 还有更多方法可以完成相同的工作吗 scaladoc 的链接也可能有帮助 D 所有这些方法都是将两个流合并为一个流所必需的 例如 您可以创建
akkastream
监控封闭图 Akka Stream
如果我创建了一个RunningGraph在 Akka Stream 中 我怎么知道 从外部 当所有节点因完成而被取消时 当所有节点因错误而停止时 我认为没有办法对任意图执行此操作 但是如果您可以控制图 则只需将监视接收器附加到每个可能失败或
scala
akkastream
如何实现Actor.Ask以一定速率控制数据流
我使用了下面的方法 但它使用了大量的 CPU 所以我想使用 Actor Ask 而不是下面的方法 任何人都可以帮助我如何使用 Actor Ask KafkaConsumer PlainSource consumerSettings subs
c
NET
akkastream
akkanet
如何订阅在不同 JVM 上运行的反应式流实现?
假设我们有两个 Akka Stream 流 每个流都在自己的 JVM 上运行 A reactive streams publisher running on JVM 1 val stringPublisher Publisher Strin
JVM
akkastream
reactivestreams
通过连接池发出 http 请求时 Akka Flow 挂起
我正在使用 Akka 2 4 4 并尝试从 Apache HttpAsyncClient 迁移 未成功 下面是我在项目中使用的代码的简化版本 问题是 如果我向流程发送超过 1 3 个请求 它就会挂起 到目前为止 经过6个小时的调试 我什至找
scala
akka
akkastream
akkahttp
如何通过 Scala 中的 Play Framework 2.5 流式传输压缩文件(即时)?
我想流式传输一些文件并即时压缩它们 以便用户可以将多个文件下载到一个压缩文件中 而无需向本地磁盘写入任何内容 但是 我当前的实现将所有内容保存在内存中 并且不适用于大文件 有什么办法可以解决吗 我正在研究这个实现 https gist gi
scala
playframework
zip
akka
akkastream
使用 slick 3.0.0 流结果和 Postgresql 的正确方法是什么?
我正在尝试弄清楚如何使用流畅的流媒体 我使用 slick 3 0 0 和 postgres 驱动程序 情况如下 服务器必须向客户端提供按大小 以字节为单位 限制的数据块分割的数据序列 因此 我编写了以下巧妙的查询 val sequences
postgresql
scala
slick
slick30
akkastream
为什么 Akka Streams 会吞掉我的异常?
为什么异常在 import akka actor ActorSystem import akka stream ActorMaterializer import akka stream scaladsl Source object Test
scala
Exception
akkastream
groupBy 的子流可以依赖于它们生成的键吗?
我有一个包含与用户关联的数据的流程 我还为每个用户提供了一个状态 我可以从数据库异步获取该状态 我想将我的流与每个用户一个子流分开 并在具体化子流时加载每个用户的状态 以便可以根据该状态来处理子流的元素 如果我不想合并下游的子流 我可以做一
scala
akkastream
如何开始使用 Akka Streams? [关闭]
Closed 这个问题需要多问focused help closed questions 目前不接受答案 Akka Streams 库已经提供了相当多的丰富的文档 http doc akka io docs akka 2 4 2 RC1 s
scala
akkastream
Akka Stream 和 Kamon-Prometheus 不返回任何指标,但加载空页面
我尝试将 kamon prometheus 与 akka Stream 项目集成 但在http 本地主机 9095 http localhost 9095 它加载一个空页面 在控制台中 我可以看到一条消息 表明指标信息可在http 本地主机
Prometheus
akkastream
kamon
akkamonitoring
端到端反应式流媒体 RESTful 服务(也称为 HTTP 上的背压)
我一直试图在网上澄清这个问题一段时间但没有成功 所以我会尝试在这里提问 我想找到一些资源或示例 其中展示了如何构建端到端完全背压的 REST 服务 客户端 我的意思是 我希望看到 给定一个实现响应式流的 REST 客户端 无论是在 Akka
scala
REST
akka
akkastream
reactivestreams
如何使用源队列并将其返回给调用者而不具体化它?
我正在尝试使用新的 Akka 流 想知道如何使用源队列并将其返回给调用者 而不在我的代码中实现它 想象一下 我们有一个库可以进行多次异步调用并通过以下方式返回结果Source 函数看起来像这样 def findArticlesByTitle
scala
akka
akkastream
Akka 流 2.6。如何创建ActorMaterializer?
从 2 6 开始 我在这一行收到弃用警告 import akka stream ActorMaterializer implicit val actorMaterializer ActorMaterializer 警告 不推荐使用 Acto
scala
akkastream
MergeLatest 的默认值
官方文档 https doc akka io docs akka current stream operators Source or Flow mergeLatest html of MergeLatest状态 MergeLatest 为
scala
akka
akkastream
akka-streams 与 akka-cluster
我的 akka streams 学习马拉松仍在继续 我想将我的 akka streams 应用程序与akka cluster 和 DistributedPubSubMediator http doc akka io docs akka sn
scala
akka
akkacluster
akkastream
1
2
3
»