problem: call already closed exception, onError closes it

2019-06-14 18:20:38 -04:00
parent 8beeb0877a
commit b8a7d4e3db
1 changed files with 0 additions and 1 deletions
--- 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)