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) <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
