fix

digital-asset · Sep 26, 2024 · f09a26b · f09a26b
1 parent 7c8be97
commit f09a26b
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/sdk/observability/metrics/src/main/scala/com/daml/metrics/InstrumentedGraph.scala b/sdk/observability/metrics/src/main/scala/com/daml/metrics/InstrumentedGraph.scala
@@ -26,6 +26,8 @@ object InstrumentedGraph {
       delayTimer: Timer,
   ) extends BoundedSourceQueue[T] {
 
+    override def isCompleted: Boolean = delegate.isCompleted
+
     override def complete(): Unit = {
       delegate.complete()
       capacityCounter.dec(bufferSize.toLong)(MetricsContext.Empty)