node: fix IRSSimulation so it doesn't rely on buffering

This commit is contained in:
Andras Slemmer 2016-06-16 16:04:48 +01:00
parent 5323eb1073
commit ccf362bb8a

View File

@ -105,8 +105,8 @@ class IRSSimulation(networkSendManuallyPumped: Boolean, runAsync: Boolean, laten
val retFuture = SettableFuture.create<Unit>()
val futA = node1.smm.add("floater", sideA)
val futB = node2.smm.add("fixer", sideB)
executeOnNextIteration += {
val futB = node2.smm.add("fixer", sideB)
Futures.allAsList(futA, futB) success {
retFuture.set(null)
} failure { throwable ->