diff --git a/amethyst/src/main/java/com/vitorpamplona/amethyst/service/playback/websocket/WssDataStreamCollector.kt b/amethyst/src/main/java/com/vitorpamplona/amethyst/service/playback/websocket/WssDataStreamCollector.kt
index 0ca26eccf..c59521c07 100644
--- a/amethyst/src/main/java/com/vitorpamplona/amethyst/service/playback/websocket/WssDataStreamCollector.kt
+++ b/amethyst/src/main/java/com/vitorpamplona/amethyst/service/playback/websocket/WssDataStreamCollector.kt
@@ -41,10 +41,10 @@ class WssDataStreamCollector : WebSocketListener() {
         reason: String,
     ) {
         super.onClosing(webSocket, code, reason)
-        wssData.removeAll(wssData)
+        wssData.clear()
     }
 
-    fun canStream(): Boolean = wssData.size > 0
+    fun canStream(): Boolean = wssData.isNotEmpty()
 
     fun getNextStream(): ByteString = wssData.pollFirst()
 }