From 8d19e161ab044dc7c2c9f6b8db6673fc0a6cde1f Mon Sep 17 00:00:00 2001 From: Erik van Oosten Date: Sat, 27 Apr 2024 09:52:16 +0200 Subject: [PATCH] Formatting --- zio-kafka/src/main/scala/zio/kafka/consumer/Consumer.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/zio-kafka/src/main/scala/zio/kafka/consumer/Consumer.scala b/zio-kafka/src/main/scala/zio/kafka/consumer/Consumer.scala index f571ee381..d085b664f 100644 --- a/zio-kafka/src/main/scala/zio/kafka/consumer/Consumer.scala +++ b/zio-kafka/src/main/scala/zio/kafka/consumer/Consumer.scala @@ -726,7 +726,8 @@ private[consumer] final class ConsumerLive private[consumer] ( for { control <- streamControl fib <- withStream(control.stream) - .onInterrupt(ZIO.logError("withStream in runWithGracefulShutdown interrupted, this should not happen")).forkScoped + .onInterrupt(ZIO.logError("withStream in runWithGracefulShutdown interrupted, this should not happen")) + .forkScoped result <- fib.join.onInterrupt( control.stop *> fib.join