You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pekko.apache.org by he...@apache.org on 2024/03/15 01:54:23 UTC
(incubator-pekko) branch 1.0.x updated: chore:Fix up typos for unfoldResource* operators. (#1190) (#1191)
This is an automated email from the ASF dual-hosted git repository.
hepin pushed a commit to branch 1.0.x
in repository https://gitbox.apache.org/repos/asf/incubator-pekko.git
The following commit(s) were added to refs/heads/1.0.x by this push:
new 48950bf61e chore:Fix up typos for unfoldResource* operators. (#1190) (#1191)
48950bf61e is described below
commit 48950bf61ee2cc3658eecd3e5a3fc790677ca903
Author: He-Pin(kerr) <he...@gmail.com>
AuthorDate: Fri Mar 15 09:54:19 2024 +0800
chore:Fix up typos for unfoldResource* operators. (#1190) (#1191)
(cherry picked from commit 7eef4e017ddcbe5c475b82aa4af0ce00940e5368)
---
stream/src/main/scala/org/apache/pekko/stream/javadsl/Source.scala | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/stream/src/main/scala/org/apache/pekko/stream/javadsl/Source.scala b/stream/src/main/scala/org/apache/pekko/stream/javadsl/Source.scala
index f234ad222f..93a456f784 100755
--- a/stream/src/main/scala/org/apache/pekko/stream/javadsl/Source.scala
+++ b/stream/src/main/scala/org/apache/pekko/stream/javadsl/Source.scala
@@ -829,7 +829,7 @@ object Source {
*
* @param create - function that is called on stream start and creates/opens resource.
* @param read - function that reads data from opened resource. It is called each time backpressure signal
- * is received. Stream calls close and completes when `read` returns None.
+ * is received. Stream calls close and completes when `read` returns an empty Optional.
* @param close - function that closes resource
*/
def unfoldResource[T, S](
@@ -855,7 +855,7 @@ object Source {
*
* @param create - function that is called on stream start and creates/opens resource.
* @param read - function that reads data from opened resource. It is called each time backpressure signal
- * is received. Stream calls close and completes when `CompletionStage` from read function returns None.
+ * is received. Stream calls close and completes when `CompletionStage` from read function returns an empty Optional.
* @param close - function that closes resource
*/
def unfoldResourceAsync[T, S](
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org