How about something like:
complete {
Source.single(yourResponse).via(Flow.delay(delayDuration)).to(Sink.head).run()
}
I'm shooting from the hip here, you may need to use the type of your
response as parameter somewhere in the middle.
The idea is that Sink.head[T] materializes into a Future[T] so the response
will be completed asynchronously when delay duration elapses.
Cheers,
Rafał
W dniu wtorek, 28 marca 2017 10:39:09 UTC+2 użytkownik Alan Burlison
napisał:
>
> I'm working on a simulation using Akka HTTP where the HTTP responses
> from the real system can have significant delays that I need to
> replicate. Doing this the simple way by blocking on a sleep would
> obviously not be a good choice so I'm wondering on how to do this? One
> idea is to use the Akka Scheduler
> (http://doc.akka.io/docs/akka/current/scala/scheduler.html) to send a
> message back to the HTTP actor after a delay containing the response to
> send back to the client, but I'm wondering if there's a smarter way to
> do this?
>
> Thanks,
>
> --
> Alan Burlison
> --
>
--
>>>>>>>>>> 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.
