Skip to content

Commit

Permalink
Remove unused annotation
Browse files Browse the repository at this point in the history
  • Loading branch information
svroonland committed May 20, 2024
1 parent 33a6d82 commit a155267
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions zio-kafka/src/main/scala/zio/kafka/consumer/Consumer.scala
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,6 @@ import zio.kafka.serde.{ Deserializer, Serde }
import zio.kafka.utils.SslHelper
import zio.stream._

import scala.annotation.unused
import scala.jdk.CollectionConverters._
import scala.util.control.NoStackTrace

Expand Down Expand Up @@ -719,7 +718,7 @@ private[consumer] final class ConsumerLive private[consumer] (
*/
private def runWithGracefulShutdown[StreamType <: ZStream[_, _, _], R, E](
streamControl: ZIO[Scope, E, SubscriptionStreamControl[StreamType]],
@unused shutdownTimeout: Duration
shutdownTimeout: Duration
)(
withStream: StreamType => ZIO[R, E, Any]
): ZIO[R, E, Any] =
Expand Down

0 comments on commit a155267

Please sign in to comment.