ExternalVendorCode/corda
1
0
Fork 0
mirror of https://github.com/corda/corda.git synced 2024-12-22 06:17:55 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

Missed some protocol mentions

Browse Source
This commit is contained in:
rick.parker 2016-11-23 08:55:21 +00:00
parent 29c38ea82a
commit bf88dc4826
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
client/src/integration-test/kotlin/net/corda/client/CordaRPCClientTest.kt
View File

@ -75,12 +75,12 @@ class CordaRPCClientTest {
client.start(rpcUser.username, rpcUser.password) client.start(rpcUser.username, rpcUser.password)
println("Creating proxy") println("Creating proxy")
val proxy = client.proxy() val proxy = client.proxy()
println("Starting protocol") println("Starting flow")
val protocolHandle = proxy.startFlow(::CashFlow, CashCommand.IssueCash(20.DOLLARS, OpaqueBytes.of(0), driverInfo.nodeInfo.legalIdentity, driverInfo.nodeInfo.legalIdentity)) val flowHandle = proxy.startFlow(::CashFlow, CashCommand.IssueCash(20.DOLLARS, OpaqueBytes.of(0), driverInfo.nodeInfo.legalIdentity, driverInfo.nodeInfo.legalIdentity))
println("Started protocol, waiting on result") println("Started flow, waiting on result")
protocolHandle.progress.subscribe { flowHandle.progress.subscribe {
println("PROGRESS $it") println("PROGRESS $it")
} }
println("Result: ${protocolHandle.returnValue.toBlocking().first()}") println("Result: ${flowHandle.returnValue.toBlocking().first()}")
} }
} }