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 2025/10/19 15:34:10 UTC
(pekko) 01/01: chore: Update since version of Sink source and count
This is an automated email from the ASF dual-hosted git repository.
hepin pushed a commit to branch updateSince
in repository https://gitbox.apache.org/repos/asf/pekko.git
commit c3eba2b2556a55cf7e07f5c2ae7e874315929de5
Author: He-Pin <he...@gmail.com>
AuthorDate: Sun Oct 19 23:33:57 2025 +0800
chore: Update since version of Sink source and count
---
stream/src/main/scala/org/apache/pekko/stream/scaladsl/Sink.scala | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/stream/src/main/scala/org/apache/pekko/stream/scaladsl/Sink.scala b/stream/src/main/scala/org/apache/pekko/stream/scaladsl/Sink.scala
index 96d7fe622b..03f97f94f8 100644
--- a/stream/src/main/scala/org/apache/pekko/stream/scaladsl/Sink.scala
+++ b/stream/src/main/scala/org/apache/pekko/stream/scaladsl/Sink.scala
@@ -275,7 +275,7 @@ object Sink {
* '''Cancels when''' never
*
* @return a `Sink` that materializes to a `Future[Long]` with the element count
- * @since 2.0.0
+ * @since 1.3.0
*
* See also [[Flow.limit]], [[Flow.limitWeighted]], [[Flow.take]], [[Flow.takeWithin]], [[Flow.takeWhile]]
*/
@@ -321,7 +321,7 @@ object Sink {
* Note: even if the `Source` is directly connected to the `Sink`, there is still an asynchronous boundary
* between them; performance may be improved in the future.
*
- * @since 2.0.0
+ * @since 1.3.0
*/
def source[T]: Sink[T, Source[T, NotUsed]] = _sourceSink.asInstanceOf[Sink[T, Source[T, NotUsed]]]
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org