Merge pull request #29 from p2p-org/fix_subscribe_fllter

fix filter
2022-10-18 18:43:56 +03:00
parent 07d97029a5 b3305fdeea
commit 50e8b05fbe
2 changed files with 2 additions and 2 deletions
--- a/src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum/EthereumMultistream.kt
+++ b/src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum/EthereumMultistream.kt
@@ -103,7 +103,7 @@ open class EthereumMultistream(
        upstreams.filter {
            matcher.matches(it)
        }.takeIf { ups ->
-            ups.all { it.isGrpc() }
+            ups.isNotEmpty() && ups.all { it.isGrpc() }
        }?.map {
            it as GrpcUpstream
        }?.map {
--- a/src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum_pos/EthereumPosMultiStream.kt
+++ b/src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum_pos/EthereumPosMultiStream.kt
@@ -98,7 +98,7 @@ open class EthereumPosMultiStream(
        upstreams.filter {
            matcher.matches(it)
        }.takeIf { ups ->
-            ups.all { it.isGrpc() }
+            ups.isNotEmpty() && ups.all { it.isGrpc() }
        }?.map {
            it as GrpcUpstream
        }?.map {