Hi all,
I am trying to build a flow, which will return CompletionStage with the
List inside. It looks like following:
private CompletionStage<List<Response>> buildAndRunGraph(ArrayList<Data>
sourceList) {
Source<Data, NotUsed> source = Source.from(sourceList);
Materializer materializer = ActorMaterializer.create(context());
return source.via(balancer(buildFinderFlow(), sourceList.size(),
false)).runWith(Sink.seq(), materializer);
}
The flow itself looks like following:
<https://lh3.googleusercontent.com/-xcZRmr1fRjA/WGKiaWar2pI/AAAAAAAABPo/qydmGNfqarUtHZticT_AELKraHEhBdoLwCLcB/s1600/Flow.png>
First two elements in the flow with multiple inlets and outlets are Merge
and Partition. Third one (with two outlets) is custom FanOutShape2 which
redirects message to one of two outlets based on condition.
Flow itself is working, I added loging in it and if Source contains 55
elements, then 55 results will be in the Sink, but resulted CompletionStage
doesn't complete. It waits for some miracle which never happens.
Could you please tell me how to fix that?
Thank you in advance!
Cheers,
Sergey
--
>>>>>>>>>> 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.
