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 S
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]
