diff --git a/src/main/kotlin/chatserver/messages/LocalChatMessages.kt b/src/main/kotlin/chatserver/messages/LocalChatMessages.kt
index d49b73c..cbf7ec6 100644
--- a/src/main/kotlin/chatserver/messages/LocalChatMessages.kt
+++ b/src/main/kotlin/chatserver/messages/LocalChatMessages.kt
@@ -29,7 +29,7 @@ class LocalChatMessages(
     override fun subscribe() {
         samples =
             scope.launch {
-                source().onEach { println(it) }.cancellable().collect { latestMessage ->
+                source().cancellable().collect { latestMessage ->
                     _events.update { allMessages ->
                         allMessages + latestMessage
                     }