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

Merge pull request #17986 from 2m/wip-17093-missing-supervision-2m

Browse source 
=doc #17093 mention components that do not honour supervision attribute
This commit is contained in:
Konrad Malawski 2015-07-14 13:05:49 +02:00
commit ed343f7898
2 changed files with 14 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

9
akka-docs-dev/rst/java/stream-error.rst
View file

@ -8,6 +8,11 @@ Strategies for how to handle exceptions from processing stream elements can be d
materializing the stream. The error handling strategies are inspired by actor supervision materializing the stream. The error handling strategies are inspired by actor supervision
strategies, but the semantics have been adapted to the domain of stream processing. strategies, but the semantics have been adapted to the domain of stream processing.
.. warning::
*ZipWith*, *FlexiMerge*, *FlexiRoute* junction, *ActorPublisher* source and *ActorSubscriber* sink
components do not honour the supervision strategy attribute yet.
Supervision Strategies Supervision Strategies
====================== ======================
@ -29,7 +34,7 @@ The default supervision strategy for a stream can be defined on the settings of
.. includecode:: ../../../akka-samples/akka-docs-java-lambda/src/test/java/docs/stream/FlowErrorDocTest.java#resume .. includecode:: ../../../akka-samples/akka-docs-java-lambda/src/test/java/docs/stream/FlowErrorDocTest.java#resume
Here you can see that all ``ArithmeticException`` will resume the processing, i.e. the Here you can see that all ``ArithmeticException`` will resume the processing, i.e. the
elements that cause the division by zero are effectively dropped. elements that cause the division by zero are effectively dropped.
.. note:: .. note::
@ -41,7 +46,7 @@ The supervision strategy can also be defined for all operators of a flow.
.. includecode:: ../../../akka-samples/akka-docs-java-lambda/src/test/java/docs/stream/FlowErrorDocTest.java#resume-section .. includecode:: ../../../akka-samples/akka-docs-java-lambda/src/test/java/docs/stream/FlowErrorDocTest.java#resume-section
``Restart`` works in a similar way as ``Resume`` with the addition that accumulated state, ``Restart`` works in a similar way as ``Resume`` with the addition that accumulated state,
if any, of the failing processing stage will be reset. if any, of the failing processing stage will be reset.
.. includecode:: ../../../akka-samples/akka-docs-java-lambda/src/test/java/docs/stream/FlowErrorDocTest.java#restart-section .. includecode:: ../../../akka-samples/akka-docs-java-lambda/src/test/java/docs/stream/FlowErrorDocTest.java#restart-section

9
akka-docs-dev/rst/scala/stream-error.rst
View file

@ -8,6 +8,11 @@ Strategies for how to handle exceptions from processing stream elements can be d
materializing the stream. The error handling strategies are inspired by actor supervision materializing the stream. The error handling strategies are inspired by actor supervision
strategies, but the semantics have been adapted to the domain of stream processing. strategies, but the semantics have been adapted to the domain of stream processing.
.. warning::
*ZipWith*, *FlexiMerge*, *FlexiRoute* junction, *ActorPublisher* source and *ActorSubscriber* sink
components do not honour the supervision strategy attribute yet.
Supervision Strategies Supervision Strategies
====================== ======================
@ -29,7 +34,7 @@ The default supervision strategy for a stream can be defined on the settings of
.. includecode:: code/docs/stream/FlowErrorDocSpec.scala#resume .. includecode:: code/docs/stream/FlowErrorDocSpec.scala#resume
Here you can see that all ``ArithmeticException`` will resume the processing, i.e. the Here you can see that all ``ArithmeticException`` will resume the processing, i.e. the
elements that cause the division by zero are effectively dropped. elements that cause the division by zero are effectively dropped.
.. note:: .. note::
@ -41,7 +46,7 @@ The supervision strategy can also be defined for all operators of a flow.
.. includecode:: code/docs/stream/FlowErrorDocSpec.scala#resume-section .. includecode:: code/docs/stream/FlowErrorDocSpec.scala#resume-section
``Restart`` works in a similar way as ``Resume`` with the addition that accumulated state, ``Restart`` works in a similar way as ``Resume`` with the addition that accumulated state,
if any, of the failing processing stage will be reset. if any, of the failing processing stage will be reset.
.. includecode:: code/docs/stream/FlowErrorDocSpec.scala#restart-section .. includecode:: code/docs/stream/FlowErrorDocSpec.scala#restart-section