From 3f4d52ece8eb71ae71bd1196547f14469316a807 Mon Sep 17 00:00:00 2001
From: "AndyChen(Jingzhang)" <iRoiocam@gmail.com>
Date: Thu, 27 Jun 2024 14:30:25 +0800
Subject: [PATCH] feat: add QueueClosed singleton instance for Java API (#1377)

---
 .../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
 }