From 0780d6051e0d71f7f7c34ea554d13465ed0705ff Mon Sep 17 00:00:00 2001 From: Dominic Fox Date: Wed, 18 Jul 2018 15:21:04 +0100 Subject: [PATCH] Use startFlowAndRunNetwork --- .../kotlin/net/corda/core/flows/ReceiveAllFlowTests.kt | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/core/src/test/kotlin/net/corda/core/flows/ReceiveAllFlowTests.kt b/core/src/test/kotlin/net/corda/core/flows/ReceiveAllFlowTests.kt index 14458dcefb..3d1db0c11d 100644 --- a/core/src/test/kotlin/net/corda/core/flows/ReceiveAllFlowTests.kt +++ b/core/src/test/kotlin/net/corda/core/flows/ReceiveAllFlowTests.kt @@ -59,7 +59,7 @@ class ReceiveMultipleFlowTests : WithMockNet { } assert.that( - nodes[0].startFlow(initiatingFlow).andRunNetwork(), + nodes[0].startFlowAndRunNetwork(initiatingFlow), succeedsWith(isA(equalTo(answer)))) } @@ -71,8 +71,7 @@ class ReceiveMultipleFlowTests : WithMockNet { nodes[2].registerAnswer(AlgorithmDefinition::class, stringValue) assert.that( - nodes[0].startFlow(ParallelAlgorithmMap(nodes[1].info.singleIdentity(), nodes[2].info.singleIdentity())) - .andRunNetwork(), + nodes[0].startFlowAndRunNetwork(ParallelAlgorithmMap(nodes[1].info.singleIdentity(), nodes[2].info.singleIdentity())), succeedsWith(equalTo(doubleValue * stringValue.length))) } @@ -84,8 +83,7 @@ class ReceiveMultipleFlowTests : WithMockNet { nodes[2].registerAnswer(ParallelAlgorithmList::class, value2) assert.that( - nodes[0].startFlow(ParallelAlgorithmList(nodes[1].info.singleIdentity(), nodes[2].info.singleIdentity())) - .andRunNetwork(), + nodes[0].startFlowAndRunNetwork(ParallelAlgorithmList(nodes[1].info.singleIdentity(), nodes[2].info.singleIdentity())), succeedsWith(equalTo(listOf(value1, value2)))) }