Hi,
I am trying to create a graph with custom logic of shapes as it was
mentioned in the doc
<http://doc.akka.io/docs/akka/2.4/java/stream/stream-customize.html>. My
graph is not working and I am trying to find an error using debug. I set
break point inside the GraphStageLogic:
@Override
public GraphStageLogic createLogic(Attributes inheritedAttributes) throws
Exception {
return new GraphStageLogic(shape) {
{
setHandler(in, new AbstractInHandler() {
@Override
public void onPush() throws Exception {
Data result = process(grab(in), materializer());
//break point is gere.
push(out0, result);
}
});
setHandler(out0, new AbstractOutHandler() {
@Override
public void onPull() throws Exception {
pull(in);
//And here
}
});
}
};
}
The problem is that debug doesn't stop on break points.
I run my graph with runWith function:
private CompletionStage<List<Response>> buildAndRunGraph(ArrayList<Data>
sourceList) {
Source<SubPathFinderData, NotUsed> source = Source.from(sourceList);
//List contains 21 element
Materializer materializer = ActorMaterializer.create(context());
return source.via(balancer(buildFinderFlow(), sourceList.size(),
false)).runWith(Sink.seq(), materializer);
}
Could you please help me with this issue?
Thank you in advance!
Regards,
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.
