From ebf6c11b910b66d53fa48f7061361ec8c3a70e7e Mon Sep 17 00:00:00 2001 From: Matthieu Baechler Date: Tue, 20 Dec 2022 10:29:49 +0100 Subject: [PATCH] fixup! GH-765 implement Channel.listenR --- modules/core/shared/src/main/scala/Channel.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/modules/core/shared/src/main/scala/Channel.scala b/modules/core/shared/src/main/scala/Channel.scala index 9f7086b7..67785f43 100644 --- a/modules/core/shared/src/main/scala/Channel.scala +++ b/modules/core/shared/src/main/scala/Channel.scala @@ -140,7 +140,7 @@ object Channel { } yield stream.filter(_.channel === name) - def notify(message: String): F[Unit] = + def notify(message: String): F[Unit] = // TODO: escape the message proto.execute(Command(s"NOTIFY ${name.value}, '$message'", Origin.unknown, Void.codec)).void