我编写了一个连接到我的节点并启动流的 RPC 客户端。如果我的 RPC 客户端在流完成之前断开连接,如何检索流并检查其状态(例如,它是否已完成(?
流在启动时返回唯一标识符。如果将此唯一标识符存储在某个位置,则可以稍后使用它来检索流并检查其状态,例如,通过打印其当前进度跟踪器步骤:
val flowId = cordaRPCOps.startFlowDynamic(MyFlow::class.java).id
val flow = cordaRPCOps.stateMachinesSnapshot().single { it.id == flowId }
val flowSteps = flow.progressTrackerStepAndUpdates!!
println(flowSteps.snapshot.last())