From b8a7d4e3db12836475520fa394c2745e52499ae5 Mon Sep 17 00:00:00 2001
From: Igor Artamonov <igor@artamonov.ru>
Date: Fri, 14 Jun 2019 18:20:38 -0400
Subject: [PATCH] problem: call already closed exception, onError closes it

---
 src/main/kotlin/io/emeraldpay/dshackle/rpc/StreamHead.kt | 1 -
 1 file changed, 1 deletion(-)

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)