akka有关的问题


Akka流物化价值

我想从流中引用物化值。下面是代码片段,但它没有编译,错误:
类型不匹配;
找到 :( akka.NotUsed,scala.concurrent.Future[akka.Done])
要求.


需要DB调用的CQRS命令验证

在CQRS中,验证需要DB调用的命令的最佳方法是什么?
例如,我有订单聚合,它正在验证一个命令,比如CommitOrder,我不想接受这个命令unl.