Fix another test (#558)
This commit is contained in:
@@ -437,15 +437,9 @@ class GenericWsHeadTest {
|
|||||||
Duration.ofSeconds(60),
|
Duration.ofSeconds(60),
|
||||||
)
|
)
|
||||||
|
|
||||||
StepVerifier.create(wsHead.getFlux())
|
StepVerifier.create(wsHead.headLiveness())
|
||||||
.then { wsHead.start() }
|
.then { wsHead.start() }
|
||||||
.expectNext(BlockContainer.from(block1))
|
.expectNext(HeadLivenessState.FATAL_ERROR)
|
||||||
.then {
|
|
||||||
StepVerifier.create(wsHead.headLiveness())
|
|
||||||
.expectNext(HeadLivenessState.FATAL_ERROR)
|
|
||||||
.thenCancel()
|
|
||||||
.verify(Duration.ofSeconds(2))
|
|
||||||
}
|
|
||||||
.thenCancel()
|
.thenCancel()
|
||||||
.verify(Duration.ofSeconds(3))
|
.verify(Duration.ofSeconds(3))
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user