Skip to content

Commit

Permalink
Formatting
Browse files Browse the repository at this point in the history
  • Loading branch information
erikvanoosten committed Apr 27, 2024
1 parent 6e25cd4 commit 8d19e16
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion zio-kafka/src/main/scala/zio/kafka/consumer/Consumer.scala
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit 8d19e16

Please sign in to comment.