Just replace the /scala/ in the url to /java/ :-)
So it becomes:
http://doc.akka.io/docs/akka/2.4.9/java/stream/stream-graphs.html
All Akka APIs have 100% coverage in both languages / DSLs.
The Java / Scala API for GraphStage is exactly the same class btw, so you
can read any blogs etc about it
Thanks a lot! It is exactly what I need, but can I do the same in Java?
Regards,
Sergey
четверг, 25 августа 2016 г., 21:16:44 UTC+3 пользователь Konrad Malawski
написал:
>
> If it has more than 1 input and 1 output it's not a Flow anymore, so let's
> not refer to it as a Flow.
> It's a Graph
If it has more than 1 input and 1 output it's not a Flow anymore, so let's
not refer to it as a Flow.
It's a Graph of a given Shape.
There's nothing special about Shape, so if you want a custom one, you
simply extend Shape, as is documented in the reference docs:
Thanks a lot for your response.
However it is still not clear.
I am talking about FlowShape with several Inlets and Outlets. As I
understood
from:
http://doc.akka.io/docs/akka/2.4/java/stream/stream-customize.html#Custom_linear_processing_stages_using_GraphStage
I have to create Shape by
Handlers have no shape. The GraphStage does.
So your stage has some shape.
And then you set as many handlers as you need.
Still simple sources and sinks, but we just published a blog post
explaining it a bit more:
http://blog.akka.io/integrations/2016/08/25/simple-sink-source-with-graphstage
Hi,
I am trying to create multi input/output flow. It should obtain messages
from different Inlets and emit to different Outlets based on parameter
inside the message.
Something like following:
1. ...
A elem = grab(in1);
2.if (p.test(elem)) {
3.
