From 6e0a2caf4b89674f8cd55108e540c032883091e9 Mon Sep 17 00:00:00 2001 From: Jacek Kunicki Date: Thu, 14 Jul 2016 21:54:33 +0200 Subject: [PATCH] Corrected onPush description in Custom stream processing docs #20959 (#20960) --- akka-docs/rst/java/stream/stream-customize.rst | 2 +- akka-docs/rst/scala/stream/stream-customize.rst | 3 +-- 2 files changed, 2 insertions(+), 3 deletions(-) diff --git a/akka-docs/rst/java/stream/stream-customize.rst b/akka-docs/rst/java/stream/stream-customize.rst index fa6bf82473..691a38c628 100644 --- a/akka-docs/rst/java/stream/stream-customize.rst +++ b/akka-docs/rst/java/stream/stream-customize.rst @@ -105,7 +105,7 @@ The following operations are available for *input* ports: The events corresponding to an *input* port can be received in an :class:`AbstractInHandler` instance registered to the input port using ``setHandler(in, handler)``. This handler has three callbacks: -* ``onPush()`` is called when the output port has now a new element. Now it is possible to acquire this element using +* ``onPush()`` is called when the input port has now a new element. Now it is possible to acquire this element using ``grab(in)`` and/or call ``pull(in)`` on the port to request the next element. It is not mandatory to grab the element, but if it is pulled while the element has not been grabbed it will drop the buffered element. * ``onUpstreamFinish()`` is called once the upstream has completed and no longer can be pulled for new elements. diff --git a/akka-docs/rst/scala/stream/stream-customize.rst b/akka-docs/rst/scala/stream/stream-customize.rst index fbefb77dc1..0aaa7c7efd 100644 --- a/akka-docs/rst/scala/stream/stream-customize.rst +++ b/akka-docs/rst/scala/stream/stream-customize.rst @@ -108,7 +108,7 @@ The following operations are available for *input* ports: The events corresponding to an *input* port can be received in an :class:`InHandler` instance registered to the input port using ``setHandler(in, handler)``. This handler has three callbacks: -* ``onPush()`` is called when the output port has now a new element. Now it is possible to acquire this element using +* ``onPush()`` is called when the input port has now a new element. Now it is possible to acquire this element using ``grab(in)`` and/or call ``pull(in)`` on the port to request the next element. It is not mandatory to grab the element, but if it is pulled while the element has not been grabbed it will drop the buffered element. * ``onUpstreamFinish()`` is called once the upstream has completed and no longer can be pulled for new elements. @@ -481,4 +481,3 @@ that he gave up). It is interesting to note that a simplified form of this problem has found its way into the `dotty test suite `_. Dotty is the development version of Scala on its way to Scala 3. -