我从带有自定义主体的 singleRequest 中使用了一些数据，并且我尝试使用 Unmarshall 将其序列化为自定义 <em>
我正在设置一个带有 websocket 端点的 akka http 服务器。但是，当我的 js 客户端通过 <code>websocket.close(4001);<
我有一个 Actor，它在一个 <code>httpRequest => http.singleRequest(httpRequest).pipeTo(self)</code> 消息中使用 <code>case
我有一个包含 akka、akka http 和 akka 流的应用程序，所以它不是休息或微服务是一个短暂的应用程序；它
我正在寻找一种实现/使用扇出的方法，它接受 1 个输入，并并行广播到 N 个输出，不同之处在于我想对
我正在尝试使用多个具有与相同对象相关的事件的 kafka 主题。对于不同主题的对象，分片键是相同的，
如果我解压缩一系列元组，对两个流执行一些异步更改，然后重新压缩它们，Akka 是否保证以相同的顺序
我使用 <a href="http://reactivemongo.org/" rel="nofollow noreferrer">ReactiveMongo</a> 作为 Akka-Http、Akka-Streams 项目的连接
我有一个函数负责运行我的流，它看起来像这样：
<pre><code> def runGraph(sharedKillSwitch: SharedKillSwitch = sha
我正在尝试在 akka 流中使用 <code>completionTimeout</code>。我提供了一个人为的示例，其中流程需要 10 秒，但
有一条路线有点像这样：
<pre><code>val route =
path("data") {
get {
val src: Source[ByteString, Bounde
当我尝试对响应进行两次解组时出现此错误，这是因为我需要将响应作为案例类，并且我还需要将其作
有一个有状态的流程：
<pre><code>val stream = Flow[Event].statefulMapConcat {
() =>
val state = ...
{
e
我有一个发布到 Kafka 服务器的流 A 和一个从 Kafka 服务消费、处理然后发布到多个 Kafka 主题的流 B。
流 A
我有如下两条路线，我想将其映射到 Flow 以便我可以处理多个请求
<pre><code>val routes =
swaggerRoute ~
我预计结 Balance 会向可用的输出端口发送元素。但是如果这个端口之一因为某个任务而忙碌，那么 Balance
考虑以下类：
<pre><code>class MongoDumpService @Inject()(eventsDao: EventDAO)(implicit val ec: ExecutionContext, mat: Materiali
我正在尝试使用 <code>Consumer.committablePartitionedSource()</code> 并为每个分区创建流，如下所示
<pre><code>
根据文档，我们可以使用 Akka 流实现 SSE，如下所示：
<pre class="lang-scala prettyprint-override"><code>complete {
给定如下路线：
<pre><code>get {
complete(HttpEntity(ContentTypes.`application/json`, source))
//say source is Source[Byte
