From 7eef4e017ddcbe5c475b82aa4af0ce00940e5368 Mon Sep 17 00:00:00 2001 From: "He-Pin(kerr)" Date: Fri, 15 Mar 2024 02:17:44 +0800 Subject: [PATCH] chore:Fix up typos for unfoldResource* operators. (#1190) --- .../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 b1c7a166c9..99a54bbf0a 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 @@ -845,7 +845,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]( @@ -871,7 +871,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](