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/06/27 06:30:29 UTC
(pekko) branch main updated: feat: add QueueClosed singleton instance for Java API (#1377)
This is an automated email from the ASF dual-hosted git repository.
hepin 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 3f4d52ece8 feat: add QueueClosed singleton instance for Java API (#1377)
3f4d52ece8 is described below
commit 3f4d52ece8eb71ae71bd1196547f14469316a807
Author: AndyChen(Jingzhang) <iR...@gmail.com>
AuthorDate: Thu Jun 27 14:30:25 2024 +0800
feat: add QueueClosed singleton instance for Java API (#1377)
---
stream/src/main/scala/org/apache/pekko/stream/QueueOfferResult.scala | 5 +++++
1 file changed, 5 insertions(+)
diff --git a/stream/src/main/scala/org/apache/pekko/stream/QueueOfferResult.scala b/stream/src/main/scala/org/apache/pekko/stream/QueueOfferResult.scala
index 75e67d5409..4fbde009ff 100644
--- a/stream/src/main/scala/org/apache/pekko/stream/QueueOfferResult.scala
+++ b/stream/src/main/scala/org/apache/pekko/stream/QueueOfferResult.scala
@@ -76,4 +76,9 @@ object QueueOfferResult {
case object QueueClosed extends QueueCompletionResult {
override def isEnqueued: Boolean = false
}
+
+ /**
+ * Java API: The `QueueClosed` singleton instance
+ */
+ def closed: QueueOfferResult = QueueClosed
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org