Any New on this I get the same problem
here is my code
def asyncHandler(request : HttpRequest) : Future[HttpResponse] = {
request match {
case HttpRequest(POST, Uri.Path("/rtb"), _, _, _) =>
val eee = Source.single(request).via(flowAsync).runWith(Sink.head)
Hi,
I've been looking for a way to create a client that upon disconnection will
try to reconnect.
I've done this in the past with RxJava observables, but I'm not sure how to
do this using Akka Streams.
I saw some code examples where PushStage is being used to implement this,
but the code
hi,
I have a problem with defining a flow that reacts to incoming data and
producing dynamic response.
lets say I have a tcp server
Tcp
.get(system)
.bind(host, port)
.to(foreach(con -> {
con.handleWith(handlerFlow, materializer);
}))
