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 75e67d54092..4fbde009ffb 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
 }