I am not 100% sure but i think that what you are looking for is something quite similar to a problem i tried to solve. I found the answer to it on this: https://github.com/akka/akka/issues/17522
Let me know if it answers your question, else i would need to better understand it :) On Wednesday, February 24, 2016 at 10:57:38 AM UTC-5, Javier Igua wrote: > > Hi, > > Playing around with the receive pipeline pattern > <http://doc.akka.io/docs/akka/2.4.2/contrib/receive-pipeline.html> I put > together the following example to do some sort of user credentials > validation composition with an actor. > > Problem is that only with the synchronous blocking semantics I managed to > get the code compiling and running. With the other two alternatives for > asynchronous nonblocking composition I get compilation error (about not > having the proper response type por the pipeline). > > So my questions are: Am I missing something here? Does the receive > pipeline pattern only play well with blocking synchronous compositions? Is > there a way to have non-blocking asynchronous compositions with pipelines? > > /** > * Pipeline pattern for client validation, intercepts Query messages between > actors to authorize requests. > */ > trait ClientValidationPipeline { > this: ReceivePipeline => > > def clientService: ActorRef > > pipelineInner { > case query @ Query(ctx: QueryContext, body: QueryBody) => > > > implicit val timeout = Timeout(200 milliseconds) > > > */** synchronous *await impl */ > > val clientValidationFuture = clientService ? > CheckClient(ctx.clientName, ctx.clientPasswd) > val clientValidation = Await.result(clientValidationFuture, > timeout.duration) > clientValidation match { > case validClient: ValidClient => > body.principal = Some(validClient.client) > Inner(query) > case invalidClient: InvalidClient => > sender() ! invalidClient > HandledCompletely > } > > /** a*synchronous *callback impl */ > > (clientService ? CheckClient(ctx.clientName, > ctx.clientPasswd)).onComplete { > case Success(validClient: ValidClient) => > body.principal = Some(validClient.client) > Inner(query) > case Success(invalidClient: InvalidClient) => > sender() ! invalidClient > HandledCompletely > case Failure(status) => > sender() ! status > HandledCompletely > } > > /** a*synchronous *for comprehension impl */ > > val clientValidationFuture = clientService ? > CheckClient(ctx.clientName, ctx.clientPasswd) > for { > clientValidation <- clientValidationFuture > } yield { > clientValidation match { > case validClient: ValidClient => > body.principal = Some(validClient.client) > Inner(query) > case invalidClient: InvalidClient => > sender() ! invalidClient > HandledCompletely > } > } > > case x => > Inner(x) > } > } > > > Thanks, > Javier > > -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to [email protected]. To post to this group, send email to [email protected]. Visit this group at https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
