On 29/03/2017 16:38, Rafał Krzewski wrote:
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.
That's not an approach that occurred to me as I haven't played with streams - thanks, I'll investigate.
-- Alan Burlison -- --
--- You received this message because you are subscribed to the Google Groups "Akka User List" group.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
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.
