Update nsq/src/main/scala/com.snowplowanalytics.snowplow.collectors.s…

…calastream/sinks/NsqSink.scala Co-authored-by: Benjamin BENOIST <[email protected]>
snowplow · Sep 19, 2023 · 1fcdedd · 1fcdedd
1 parent 0dd668c
commit 1fcdedd
Showing 1 changed file with 0 additions and 3 deletions.
diff --git a/nsq/src/main/scala/com.snowplowanalytics.snowplow.collectors.scalastream/sinks/NsqSink.scala b/nsq/src/main/scala/com.snowplowanalytics.snowplow.collectors.scalastream/sinks/NsqSink.scala
@@ -45,9 +45,6 @@ class NsqSink[F[_]: Sync] private (
   executorService: ScheduledExecutorService
 ) extends Sink[F] {
 
-  implicit lazy val ec: ExecutionContextExecutorService =
-    concurrent.ExecutionContext.fromExecutorService(executorService)
-
   var healthStatus = true
 
   override def isHealthy: F[Boolean] = Sync[F].pure(healthStatus)