fix for scala 3

zio · Feb 5, 2025 · 67f9679 · 67f9679
1 parent 9e52f37
commit 67f9679
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/zio-kafka-test/src/test/scala/zio/kafka/utils/SlidingDiagnostics.scala b/zio-kafka-test/src/test/scala/zio/kafka/utils/SlidingDiagnostics.scala
@@ -27,7 +27,7 @@ object SlidingDiagnostics {
   def make[DiagnosticEvent](queueSize: Int = 16): ZIO[Scope, Nothing, QueuedDiagnostics[DiagnosticEvent]] =
     ZIO.acquireRelease(Queue.sliding[DiagnosticEvent](queueSize))(_.shutdown).map(QueuedDiagnostics(_))
 
-  final case class QueuedDiagnostics[DiagnosticEvent] private[QueuedDiagnostics](queue: Queue[DiagnosticEvent])
+  final case class QueuedDiagnostics[DiagnosticEvent] private[SlidingDiagnostics](queue: Queue[DiagnosticEvent])
       extends Diagnostics[DiagnosticEvent] {
     override def emit(event: => DiagnosticEvent): UIO[Unit] = queue.offer(event).unit
   }