Skip to content

Commit cbe1a2b

Browse files
committed
[CHORE] Fix it tests
1 parent c615718 commit cbe1a2b

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

src/it/scala/io/iohk/ethereum/txExecTest/util/DumpChainActor.scala

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -62,10 +62,9 @@ class DumpChainActor(peerManager: ActorRef, peerMessageBus: ActorRef, startBlock
6262
}
6363

6464
//Periodically try to connect to bootstrap peer in case the connection failed before dump termination
65-
val connectToBootstrapTimeout: Cancellable = context.system.scheduler.schedule(0 seconds, 4 seconds, () =>
66-
peerManager ! PeerManagerActor.ConnectToPeer(new URI(bootstrapNode)))
65+
val connectToBootstrapTimeout: Cancellable = context.system.scheduler.scheduleWithFixedDelay(0 seconds, 4 seconds, peerManager, PeerManagerActor.ConnectToPeer(new URI(bootstrapNode)))
6766

68-
val assignWorkTimeout: Cancellable = context.system.scheduler.schedule(0 seconds, 2 seconds, () => assignWork())
67+
val assignWorkTimeout: Cancellable = context.system.scheduler.scheduleWithFixedDelay(0 seconds, 2 seconds)(() => assignWork())
6968

7069
// scalastyle:off
7170
override def receive: Receive = {

0 commit comments

Comments
 (0)