我是Akka/Scala的新手，正在尝试调试下面的代码。当resultSetParser有一个例外时，它不会抛出它。相反，使用此代码的服务只是永远闲置。 如何让我的服务抛出异常，而不仅仅是在流中等待？在Akka中有没有类似watchException()的函数，我可以在watchTermination()之后调用它，使它在处理流时看到异常？ val chunkSource: Source[Chun
在这样的情况： Data Data;
public ParentActor(Data data)
{
Data = data;
Context.ActorOf(Props.Create(() => new ChildActor()))
}
在儿童演员是一个很好的做法，使用方法： (Context.Parent as ParentActor).Data; } } 还是这
我有一个CalculationSupervisor演员与工作人员池。 每次我需要做一些计算CalculationSupervisor广播CalculationRequest给使用路由器的工人。 我需要得到最快的计算结果并忽略其他结果。 CalculationSupervisor如下所示： public class CalculationSupervisor extends AbstractActo
在docs和here提供设置HostnameVerifierClass，我尝试使用下面的代码来改变HostnameVerifierClass： val sslConfig = AkkaSSLConfig().mapSettings { s =>
s.withHostnameVerifierClass(java.lang.Class[NoopHostnameVerifier])