From bb4fc0c7556e5fb0427da238570071c5ce321f5e Mon Sep 17 00:00:00 2001 From: Jules Ivanic Date: Sun, 17 Nov 2024 12:31:20 +1100 Subject: [PATCH] [Internal] Micro-optimisation: Reuse previously calculated `java.lang.System.nanoTime` --- .../src/main/scala/zio/kafka/consumer/internal/Runloop.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/zio-kafka/src/main/scala/zio/kafka/consumer/internal/Runloop.scala b/zio-kafka/src/main/scala/zio/kafka/consumer/internal/Runloop.scala index 8d45f8e55..945a9ce11 100644 --- a/zio-kafka/src/main/scala/zio/kafka/consumer/internal/Runloop.scala +++ b/zio-kafka/src/main/scala/zio/kafka/consumer/internal/Runloop.scala @@ -327,7 +327,7 @@ private[consumer] final class Runloop private ( for { p <- Promise.make[Throwable, Unit] startTime = java.lang.System.nanoTime() - _ <- commitQueue.offer(Runloop.Commit(java.lang.System.nanoTime(), offsets, p)) + _ <- commitQueue.offer(Runloop.Commit(startTime, offsets, p)) _ <- commandQueue.offer(RunloopCommand.CommitAvailable) _ <- diagnostics.emit(DiagnosticEvent.Commit.Started(offsets)) _ <- p.await.timeoutFail(CommitTimeout)(commitTimeout)