-
ZipOutputStream的块结果
我目前正在尝试使用Play框架2.7构建并发送zip存档。我想即时生成档案以避免使用存储(或填满RAM)。 -
如何根据某些条件处理Akka流?
假设存在一些要处理的文件流,并且满足条件时仅应处理(消耗)特定文件。<br/> 即仅当流包含 -
如何从Source [ByteString,Any] akka流中实现2个参数
这样我就可以从Source [ByteString,Any]中实现inputStream和Feature [ByteString] <pre><code>val bs = fileStream.runWith(Si -
Akka流2.6。如何创建AactorMaterializer?
从2.6开始,我在此行收到弃用警告: <pre><code>import akka.stream.ActorMaterializer implicit val actorMaterializer = Ac -
如何将数据从队列传递到客户端?
我正在尝试使用<code>akka-streams</code>编写tcp-server。 我有: <ul> <li>服务器:客户端连接服务器时 -
Akka HTTP无法通过WebSocket流式传输
我正在创建一个Akka Http路由,该路由使用WebSocket将无限量的TextMessage流传输到客户端。我忽略了来自客户 -
Akka HTTP WebSocket服务器在构建用于消息处理的Flow时如何基于接收器内容声明Source?
我正在使用Akka Stream / Http并试图弄清楚如何在websocket服务器中执行以下操作(希望不使用Actor模式): <b -
无法在Akka Stream中使用GraphStage类运行SourceShape
我正在尝试使用GraphStage构造创建Redis Akka流源。这个想法是,每当我从subscription方法获得更新时,我都会 -
使用流式ServiceCall的Lagom服务之间的背压不起作用
Lagom:1.5.4 考虑进行ServiceCall(<a href="https://github.com/an-tex/lagom-backpressure/blob/master/hello-world-stream-im -
如何使用Scala Akka流检测重复的行
我们有一个Scala应用程序,该程序可从文本文件中读取行并使用Akka Stream处理它们。为了获得更好的性能 -
如何在Alpakka S3中使用Http
如何在Alpakka中使用<code>Http().cachedHostConnectionPool(...)</code>? <br/>在文档中只有<code>val s3Client = new S3Client(se -
Alpakka S3从存储桶中下载文件,保存到文件,并具有可用于流程下一部分的文件名
我正在尝试构建使用S3密钥的代码,然后从S3下载这些文件,然后将该数据保存到具有键名的磁盘上的文 -
使用Java在Akka测试套件中测试流
<a href="https://doc.akka.io/docs/akka/current/stream/stream-testkit.html" rel="nofollow noreferrer">https://doc.akka.io/docs/akka/curre -
BroadcastHub不等待Source的首次实现
这是<em> Akka Streams </em>文档关于<code>Source</code> <code>BroadcastHub</code>(<a href="https://doc.akka.io/docs/akka/current/s -
Source.Single()会提前终止带有2个源的流
我定义了一个简单的图形,该图形将恒定流(通过<code>Source.Single(5000)</code>定义)与非恒定源(例如<code> -
akka-http net :: err_incomplete_chunked_encoding 200(确定)
我正在尝试使用Akka-http向浏览器发送较大/通常较慢的响应,以使其呈现为excel文件: 即: <h1>使用ui -
在不使用\ n字符的情况下解析json
我目前正在实现一个Akka Stream Scala应用程序,该应用程序读取一个包含如下格式推文的压缩文件(使用jso -
一次流处理的元素数量限制
AKKA中的一个如何在不删除任何元素的情况下限制流(一部分)中当前存在的元素数量? -
如何从Akka Stream读取HDFS文件?
有人可以举一个例子来通过Akka Streaming读取HDFS位置上可用的文本文件吗?我是Akka Stream的新手,在搜寻了 -
使用Akka流从迭代器创建源流时如何进行清理?
我想用JDBC <code>ResultSet</code>创建一个Akka Source流,也许用<code>fromIterator</code>。<br/> (我知道Alpakka为<code>S -
MergeLatest的默认值
<code>MergeLatest</code>的官方<a href="https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/mergeLatest.html" rel="n -
Akka StreamTcp超时重启
嗨,我正在Scala中使用lib akka创建一个TCP服务器。如果客户端在设定的时间间隔内未发送任何数据,我想 -
使用Akka流将数据分块写入文件
我使用带有akka后端的sttp lib从服务器加载文件。 下列任何一种方法都会占用大量内存,以加载1Gb文件:< -
Akka Http请求和响应模式
我有一个要求,即客户端调用通过akka http创建的post REST端点。一旦请求进入post方法,我就需要将post对象 -
如何将Source [String,Future [IOResult]]转换为Source [ByteString,Future [IOResult]]
需要转换 <pre><code>val graph: Source[String, Future[IOResult]]= <some flow> </code></pre> 到 <pre><code>val gra -
扇入式操作员累积在一个入口上
我想要一个带有两个入口的akka流运算符。在一个入口上,它接收有关消息的元数据。在第二个入口 -
使用Akka Graph实现简单的架构
我正在尝试建立一个简单的图结构,该结构通过调用rest服务来处理数据,然后将每个服务的结果转发给 -
Akka流延迟和背压
在使用Akka Streams时,我面临着缓冲和背压问题。 我有以下代码(为了简化问题而经过简化): -
通过间隔元素处理流元素
我有一个与Akka Streams有关的问题。 <a href="https://i.stack.imgur.com/be1cy.jpg" rel="nofollow noreferrer">Here is how my stre -
使用Alpakka S3连接器的多个下载请求
我正在尝试使用<a href="https://doc.akka.io/docs/alpakka/current/s3.html" rel="nofollow noreferrer">Alpakka S3 connector</a>执行