fix filter

This commit is contained in:
Maksim Fomenkov
2022-10-13 17:57:45 +03:00
parent 07d97029a5
commit b3305fdeea
2 changed files with 2 additions and 2 deletions

View File

@@ -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 {

View File

@@ -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 {