StakeSquid/dshackle
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

problem: timeout on unit tests

Browse Source
This commit is contained in:
a10zn8
2022-11-17 07:33:03 +04:00
parent ddc6fb2a4c
commit 255a3833fd
2 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum/WsConnection.kt
View File

@@ -405,7 +405,8 @@ open class WsConnection(
) )
val response = Flux.from(rpcReceive.asFlux()) val response = Flux.from(rpcReceive.asFlux())
.doOnSubscribe { sendRpc(request) } // send the request _after_ WS subscribes to the responses, otherwise the response may come before the actual subscription and be lost
.doOnRequest { sendRpc(request) }
.filter { resp -> resp.id.asNumber() == expectedId } .filter { resp -> resp.id.asNumber() == expectedId }
.take(Defaults.timeout) .take(Defaults.timeout)
.take(1) .take(1)

6
src/test/groovy/io/emeraldpay/dshackle/upstream/ethereum/WsConnectionSpec.groovy
View File

@@ -92,7 +92,7 @@ class WsConnectionSpec extends Specification {
it.id.asNumber() == 15L && Global.objectMapper.readValue(it.result, TransactionJson) == tx it.id.asNumber() == 15L && Global.objectMapper.readValue(it.result, TransactionJson) == tx
} }
.expectComplete() .expectComplete()
.verify(Duration.ofSeconds(5)) .verify(Duration.ofSeconds(1))
} }
def "Makes a RPC call - return null"() { def "Makes a RPC call - return null"() {
@@ -115,7 +115,7 @@ class WsConnectionSpec extends Specification {
it.resultAsRawString == 'null' it.resultAsRawString == 'null'
} }
.expectComplete() .expectComplete()
.verify(Duration.ofSeconds(5)) .verify(Duration.ofSeconds(1))
} }
def "Makes a RPC call - return error"() { def "Makes a RPC call - return error"() {
@@ -140,6 +140,6 @@ class WsConnectionSpec extends Specification {
it.error.code == RpcResponseError.CODE_METHOD_NOT_EXIST && it.error.message == "test" it.error.code == RpcResponseError.CODE_METHOD_NOT_EXIST && it.error.message == "test"
} }
.expectComplete() .expectComplete()
.verify(Duration.ofSeconds(5)) .verify(Duration.ofSeconds(1))
} }
} }