【发布时间】:2018-12-10 17:43:09
【问题描述】:
我使用的是 Corda 3.3。并使用收听 Cash.State 的变化,
val (snapshot, updates) = proxy.vaultTrack(Cash.State::class.java)
snapshot.states.forEach { logger.info("listen to inital pdates...."+it.toString()) }
updates.subscribe { update ->
if(update.produced.size>0)
update.produced.forEach { logger.info("listen to new produced updates ....."+it.toString()) }
if(update.consumed.size>0)
update.produced.forEach { logger.info("listen to new consumed updates ....."+it.toString()) }
}
其中代理是 rpc 连接。有趣的是,我也可以看到 Cash.State 以外的状态对象的更新。认为 proxy.vaultTrack(Cash.State::class.java) 将限制只收听 Cash.State。
【问题讨论】:
标签: corda