Remove Stream from RedisSubscriberJob

Remove fs2 as well

app/src/main/scala/RedisSubscriberJob.scala

@@ -1,8 +1,6 @@
 package lila.fishnet
 
 import cats.effect.IO
-import cats.effect.std.Queue
-import fs2.Stream
 import io.chrisdavenport.rediculous.RedisPubSub
 import org.typelevel.log4cats.Logger
 import Lila.Request
@@ -16,21 +14,11 @@ object RedisSubscriberJob:
   def apply(executor: Executor, pubsub: RedisPubSub[IO])(using Logger[IO]): RedisSubscriberJob =
     new RedisSubscriberJob:
       def run(): IO[Unit] =
-        requestStream.compile.drain
-
-      def requestStream: Stream[IO, Lila.Request] =
-        for
-          q       <- Stream.eval(Queue.unbounded[IO, Lila.Request])
-          _       <- Stream.eval(subscribe(q.offer))
-          request <- Stream.fromQueueUnterminated(q)
-        yield request
-
-      def subscribe(cb: Request => IO[Unit]): IO[Unit] =
         Logger[IO].info("Subscribing to fishnet-out") *>
           pubsub.subscribe(
             "fishnet-out",
             msg =>
-              Logger[IO].info(s"Received message: $msg") *>
+              Logger[IO].debug(s"Received message: $msg") *>
                 Lila
                   .readMoveReq(msg.message)
                   .match

build.sbt

@@ -23,7 +23,6 @@ lazy val app = project
       circeCore,
       cirisCore,
       cirisHtt4s,
-      fs2,
       http4sCirce,
       http4sDsl,
       http4sServer,

project/Dependencies.scala

@@ -5,7 +5,6 @@ object Dependencies {
   val lilaMaven = "lila-maven" at "https://raw.githubusercontent.com/lichess-org/lila-maven/master"
 
   object V {
-    val fs2         = "3.9.3"
     val circe       = "0.14.6"
     val http4s      = "0.23.23"
     val ciris       = "3.4.0"
@@ -23,8 +22,6 @@ object Dependencies {
   val catsCore   = "org.typelevel" %% "cats-core"   % "2.10.0"
   val catsEffect = "org.typelevel" %% "cats-effect" % "3.5.0"
 
-  val fs2 = "co.fs2" %% "fs2-core" % V.fs2
-
   val circeCore    = circe("core")
   val circeLiteral = circe("literal") % Test