diff --git a/src/main/kotlin/io/emeraldpay/dshackle/upstream/rpcclient/JsonRpcHttpClient.kt b/src/main/kotlin/io/emeraldpay/dshackle/upstream/rpcclient/JsonRpcHttpClient.kt index 6478290a..40273c17 100644 --- a/src/main/kotlin/io/emeraldpay/dshackle/upstream/rpcclient/JsonRpcHttpClient.kt +++ b/src/main/kotlin/io/emeraldpay/dshackle/upstream/rpcclient/JsonRpcHttpClient.kt @@ -115,11 +115,7 @@ class JsonRpcHttpClient( response.responseConnection { t, u -> streamParser.streamParse( t.status().code(), - u.inbound().receive() - .asByteArray() - .doFinally { - u.dispose() - }, + u.inbound().receive().asByteArray(), ) }.single() }