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

problem: many timeouts on CI

Browse Source
This commit is contained in:
Igor Artamonov
2022-04-02 16:47:58 -04:00
parent 5fb1a2868e
commit feb2bb89f7
2 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/test/groovy/io/emeraldpay/dshackle/upstream/ethereum/WsConnectionRealSpec.groovy
View File

@@ -63,7 +63,7 @@ class WsConnectionRealSpec extends Specification {
it.hasResult() && it.resultAsProcessedString == "baz" it.hasResult() && it.resultAsProcessedString == "baz"
} }
.expectComplete() .expectComplete()
.verify(Duration.ofSeconds(3)) .verify(Duration.ofSeconds(5))
when: when:
Thread.sleep(SLEEP) Thread.sleep(SLEEP)
@@ -159,6 +159,6 @@ class WsConnectionRealSpec extends Specification {
it.hasResult() && it.resultAsProcessedString == "baz" it.hasResult() && it.resultAsProcessedString == "baz"
} }
.expectComplete() .expectComplete()
.verify(Duration.ofSeconds(3)) .verify(Duration.ofSeconds(5))
} }
} }

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

@@ -66,7 +66,7 @@ class WsConnectionSpec extends Specification {
.then { ws.onNewHeads(headBlock).subscribe() } .then { ws.onNewHeads(headBlock).subscribe() }
.expectNext(BlockContainer.from(block)) .expectNext(BlockContainer.from(block))
.thenCancel() .thenCancel()
.verify(Duration.ofSeconds(1)) .verify(Duration.ofSeconds(5))
} }
def "Makes a RPC call"() { def "Makes a RPC call"() {
@@ -91,7 +91,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(1)) .verify(Duration.ofSeconds(5))
} }
def "Makes a RPC call - return null"() { def "Makes a RPC call - return null"() {
@@ -114,7 +114,7 @@ class WsConnectionSpec extends Specification {
it.resultAsRawString == 'null' it.resultAsRawString == 'null'
} }
.expectComplete() .expectComplete()
.verify(Duration.ofSeconds(1)) .verify(Duration.ofSeconds(5))
} }
def "Makes a RPC call - return error"() { def "Makes a RPC call - return error"() {
@@ -139,6 +139,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(1)) .verify(Duration.ofSeconds(5))
} }
} }