raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

Replace graph stage with operator

Browse source
This commit is contained in:
Richard Imaoka 2018-05-19 10:08:40 +09:00
parent f8ed3df013
commit 9784f65ced
1 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

8
akka-docs/src/main/paradox/stream/stream-customize.md
View file

@ -19,7 +19,7 @@ junctions of various kinds.
@@@ note @@@ note
A custom graph stage should not be the first tool you reach for, defining graphs using flows A custom operator should not be the first tool you reach for, defining graphs using flows
and the graph DSL is in general easier and does to a larger extent protect you from mistakes that and the graph DSL is in general easier and does to a larger extent protect you from mistakes that
might be easy to make with a custom @ref[`GraphStage`](stream-customize.md) might be easy to make with a custom @ref[`GraphStage`](stream-customize.md)
@ -183,7 +183,7 @@ An example of how this API simplifies a stage can be found below in the second v
### Custom linear processing stages using GraphStage ### Custom linear processing stages using GraphStage
Graph stages allows for custom linear processing stages through letting them GraphStage allows for custom linear processing stages through letting them
have one input and one output and using `FlowShape` as their shape. have one input and one output and using `FlowShape` as their shape.
Such a stage can be illustrated as a box with two flows as it is Such a stage can be illustrated as a box with two flows as it is
@ -366,7 +366,7 @@ implementation.
Sharing the AsyncCallback from the constructor risks race conditions, therefore it is recommended to use the Sharing the AsyncCallback from the constructor risks race conditions, therefore it is recommended to use the
`preStart()` lifecycle hook instead. `preStart()` lifecycle hook instead.
This example shows an asynchronous side channel graph stage that starts dropping elements This example shows an asynchronous side channel operator that starts dropping elements
when a future completes: when a future completes:
Scala Scala
@ -426,7 +426,7 @@ decision.
See @ref:[Modularity, Composition and Hierarchy](stream-composition.md) for an explanation on how attributes work. See @ref:[Modularity, Composition and Hierarchy](stream-composition.md) for an explanation on how attributes work.
### Rate decoupled graph stages ### Rate decoupled operators
Sometimes it is desirable to *decouple* the rate of the upstream and downstream of a stage, synchronizing only Sometimes it is desirable to *decouple* the rate of the upstream and downstream of a stage, synchronizing only
when needed. when needed.