diff --git a/src/main/kotlin/io/emeraldpay/dshackle/rpc/StreamHead.kt b/src/main/kotlin/io/emeraldpay/dshackle/rpc/StreamHead.kt
index 999761d5..60f3f6a3 100644
--- a/src/main/kotlin/io/emeraldpay/dshackle/rpc/StreamHead.kt
+++ b/src/main/kotlin/io/emeraldpay/dshackle/rpc/StreamHead.kt
@@ -59,7 +59,6 @@ class StreamHead(
         val sender = StreamSender(client)
         if (!clients.containsKey(chain)) {
             client.onError(Exception("Chain ${chain.chainCode} is not available for streaming"))
-            client.onCompleted()
             return
         }
         clients[chain]!!.add(sender)