我是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])