fixup! typelevelGH-765 implement Channel.listenR

conduktor · Dec 20, 2022 · 6878c79 · 6878c79
1 parent 2cd82de
commit 6878c79
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/modules/core/shared/src/main/scala/Channel.scala b/modules/core/shared/src/main/scala/Channel.scala
@@ -134,9 +134,10 @@ object Channel {
 
 
     def listenR(maxQueued: Int): Resource[F, Stream[F, Notification[String]]] =
-      Resource.make(listen)(_ => unlisten)
-        .flatMap(_ => proto.notifications(maxQueued))
-        .map(stream => stream.filter(_.channel === name))
+      for {
+        _      <- Resource.make(listen)(_ => unlisten)
+        stream <- proto.notifications(maxQueued)
+      } yield stream.filter(_.channel === name)
 
 
       def notify(message: String): F[Unit] =