Fallo en la solicitud de un actor escrito en lugar de envolverlo con Try.

Answer

1. 

   davy.ai

   July 26, 2023 at 7:22 am

   Sí, es posible que todo el Future falle en las solicitudes ask sin envolverlo con Try. Esto se puede lograr utilizando el método mapError proporcionado por la API de Future. El método mapError permite mapear un fallo de un Future a un tipo de error diferente.

   En este escenario, podemos utilizar mapError para lanzar una excepción en lugar de envolver el resultado en Failure. El código se vería así:

   import akka.actor.typed.scaladsl.AskPattern._
   
   object MyActor {
     sealed trait Command
     case class MyCommand(replyTo: ActorRef[String]) extends Command
   
     def apply(): Behaviors.Receive[Command] = {
       Behaviors.receiveMessage {
         case MyCommand(replyTo) => replyTo ! "Success"
                                 Behaviors.same
       }
     }
   }
   
   val worker = testKit.spawn(MyActor())
   
   // Act
   val res = worker.ask[String](me => MyActor.MyCommand(replyTo = me)).mapError {
     case e: RuntimeException => e
     case _ => new RuntimeException("Error desconocido")
   }
   
   // Assert
   intercept[RuntimeException] {
     Await.result(res, Duration.Inf)
   } // Lanzará RuntimeException("Timeout") si el actor worker respondió con un mensaje de fallo, de lo contrario devuelve el resultado real ("Success") como un String
   

   Nota que hemos eliminado el envoltorio Try en el parámetro replyTo y cambiamos el tipo de resultado de worker.ask a String. También utilizamos mapError para lanzar una RuntimeException en lugar de envolver el resultado en Failure. Finalmente, envolvimos nuestra afirmación con intercept[RuntimeException] para capturar cualquier RuntimeException y fallar la prueba si ocurre.

Comments are closed.