This is an automated email from the ASF dual-hosted git repository.
fanningpj pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko.git
The following commit(s) were added to refs/heads/main by this push:
new c76f814815 onDownstreamFinish() has been removed (#2627)
c76f814815 is described below
commit c76f814815b3788a3155581b5ec2502f7daad35b
Author: PJ Fanning <[email protected]>
AuthorDate: Thu Jan 15 14:33:08 2026 +0100
onDownstreamFinish() has been removed (#2627)
---
docs/src/main/paradox/stream/stream-customize.md | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/docs/src/main/paradox/stream/stream-customize.md
b/docs/src/main/paradox/stream/stream-customize.md
index c2a3833390..980b42910e 100644
--- a/docs/src/main/paradox/stream/stream-customize.md
+++ b/docs/src/main/paradox/stream/stream-customize.md
@@ -64,7 +64,7 @@ In order to emit from a @apidoc[stream.*.Source] in a
backpressured stream one n
To receive the necessary events one needs to register a subclass of
@scala[@scaladoc[OutHandler](pekko.stream.stage.OutHandler)]
@java[@javadoc[AbstractOutHandler](pekko.stream.stage.AbstractOutHandler)] with
the output port
(@apidoc[stream.Outlet]). This handler will receive events related to the
lifecycle of the port. In our case we need to
override `onPull()` which indicates that we are free to emit a single element.
There is another callback,
-`onDownstreamFinish()` which is called if the downstream cancelled. Since the
default behavior of that callback is
+`onDownstreamFinish(cause)` which is called if the downstream cancelled. Since
the default behavior of that callback is
to stop the operator, we don't need to override it. In the `onPull` callback
we will emit the next number. This
is how it looks like in the end:
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
