existing actors, yes
(actorpublisher actorsubscriber are other options)
--
Cheers,
√
On 22 Jul 2015 08:20, john.vie...@gmail.com wrote:
so actor stream integration always uses futures?
I am doing now:
SourceIncomingConnection, FutureServerBinding serverSource =
so actor stream integration always uses futures?
I am doing now:
SourceIncomingConnection, FutureServerBinding serverSource =
Http.get(system).bind(192.3.7.1, 8080 , materializer);
final FunctionHttpRequest, FutureHttpResponse requestHandler =
(request)-ask(actor, request,
+1
for
mapAsync + ask
:-)
--
Cheers,
Konrad 'ktoso’ Malawski
Akka @ Typesafe
On 21 July 2015 at 11:59:41, Viktor Klang (viktor.kl...@gmail.com) wrote:
mapAsync + ask?
On Tue, Jul 21, 2015 at 11:53 AM, john.vie...@gmail.com wrote:
In the code example
mapAsync + ask?
On Tue, Jul 21, 2015 at 11:53 AM, john.vie...@gmail.com wrote:
In the code example
http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0/java/stream-io.html
http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0/java/stream-io.html
connection.handleWith(echo,
