Add the queue size to the StreamOps.blockingQueue (#1400)

Netflix · Jan 3, 2022 · 68aa1b7 · 68aa1b7
1 parent bb7c911
commit 68aa1b7
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/atlas-akka/src/main/scala/com/netflix/atlas/akka/StreamOps.scala b/atlas-akka/src/main/scala/com/netflix/atlas/akka/StreamOps.scala
@@ -195,6 +195,9 @@ object StreamOps extends StrictLogging {
 
     /** Check if the queue is open to take more data. */
     def isOpen: Boolean = !completed
+
+    /** The approximate number of entries in the queue. */
+    def size: Int = queue.size()
   }
 
   /**