在事件持续存在后,我试图找到执行异步副作用(或某些操作)的最佳方法。
这是我现在正在做的
我们可以在Akka示例代码的同一JVM上设置
<pre><code>"replyTo" via context.self.
final case class Greet(whom: Str
我们正在将我们的项目迁移到键入的akka演员。我们提供的服务可以随意创建演员,例如:
<pre><co
我不明白,为什么我在“ timers.startTimerWithFixedDelay”内收到重载错误。我添加了3个参数以确保采用正确
我正在使用Akka类型的AkkaTestFramework,但找不到为我的一个类型的Actor创建ActorSystem模拟的方法。
我
我有一个由主管包裹的根本行为,如下所示。<br/>
对于<code>Exception</code>,我想在恢复之前清理本地资源
阅读<a href="https://doc.akka.io/api/akka/2.6.10/akka/actor/typed/scaladsl/Behaviors$.html" rel="nofollow noreferrer">Akka 2.6.10 API D
我曾研究过 Akka actor(非类型化),最近开始编写 Akka 类型化 actor,并发现了两种实现方式,一种是函数
我有一个类向其客户提供不同类型的 <code>Source</code>。当 <code>Source</code> 运行时,应该产生一个演员,将
我在 Akka Typed 中使用 Ask 模式时遇到了一些麻烦。我试图从演员外部发送消息,并试图关注 <a href="https://
我正在与 Akka 合作,目前我有以下协议。
<a href="https://i.stack.imgur.com/stc2f.png" rel="nofollow noreferrer"><im
所以我使用 Akka Typed,并希望将每个消息的 actor 生成到某个流中,根据文档似乎不可能:
<ul>
<li><em>
我目前正在考虑让两个不同的持久 actor 相互通信。特别是:
<pre><code>Given an Actor A exists
When an Actor B is
有没有办法在演员之外获取一些接待员列表。从文档中,我看到一些演员订阅了接待员列表的示例,但
我想拥有同一个 Akka actor 的多个实例,但具有特定的“配置”并为每个实例命名。
我想使用接待员模式
在对 Akka classic 有了基本了解后,我转向 Typed 并注意到,我的代码的 typed 版本明显比经典版本慢。
<p
我正在尝试使用 akka 类型创建一个自定义优先级邮箱框,该框根据消息类型对消息进行优先级排序。以
这个问题是不言自明的。
目前我的 web 应用程序正在启动时创建角色系统,并使用 <code>SpawnProtocol</
我对 akka 输入有点陌生,我试图发送需要在给定时间内得到答复的消息。<br/>
我发现带有 ask 的请求-响
以下是我创建行为的方式:
<pre><code>Behaviors.setup(ctx => {
ctx.system.receptionist ! Receptionist.Register(service