feat: add QueueClosed singleton instance for Java API (#1377)

2024-06-27 14:30:25 +08:00 · 2024-06-27 14:30:25 +08:00 · 3f4d52ece8
commit 3f4d52ece8
parent 3fabc04acf
1 changed files with 5 additions and 0 deletions
--- 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
 }