带有Join的列上的Corda

@InitiatingFlow
@StartableByRPC
class JoinFlows(val data1: String, val data2: String) : FlowLogic<Unit>() {
    @Suspendable
    override fun call() {
        val flowSession1 = initiateFlow(Node1Party)
        val flowSession2 = initiateFlow(Node2Party)

        val result1 = subFlow(ReceiveStateAndRefFlow::class.java, flowSession1).single().state.data
        val result2 = subFlow(ReceiveStateAndRefFlow::class.java, flowSession2).single().state.data

        // Perform the join operation
        val joinedData = result1 + result2

        // Send the joined data back to the initiators
        flowSession1.send(joinedData)
        flowSession2.send(joinedData)
    }
}

@InitiatedBy(JoinFlows::class)
class JoinFlowsResponder(val flowSession: FlowSession) : FlowLogic<Unit>() {
    @Suspendable
    override fun call() {
        val joinedData = flowSession.receive<String>().unwrap { it }
        // Process the joined data as needed
    }
}