This is an automated email from the ASF dual-hosted git repository. pjfanning pushed a commit to branch pjfanning-patch-3 in repository https://gitbox.apache.org/repos/asf/pekko-samples.git
commit 4d414705b7ff3e7078805123399a73869364ab26 Author: PJ Fanning <[email protected]> AuthorDate: Wed Sep 9 22:37:49 2026 +0100 Fix TransformCompleted parameters in Frontend.scala --- .../src/main/scala/sample/cluster/transformation/Frontend.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pekko-sample-cluster-scala/src/main/scala/sample/cluster/transformation/Frontend.scala b/pekko-sample-cluster-scala/src/main/scala/sample/cluster/transformation/Frontend.scala index 4353edf..3a76339 100644 --- a/pekko-sample-cluster-scala/src/main/scala/sample/cluster/transformation/Frontend.scala +++ b/pekko-sample-cluster-scala/src/main/scala/sample/cluster/transformation/Frontend.scala @@ -53,7 +53,7 @@ object Frontend { val text = s"hello-$jobCounter" ctx.ask(selectedWorker, Worker.TransformText(text, _)) { case Success(transformedText) => - TransformCompleted(transformedText.asInstanceOf[Worker.TransformText].text, text) + TransformCompleted(text, transformedText.text) case Failure(ex) => JobFailed("Processing timed out", text) } running(ctx, workers, jobCounter + 1) --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
