mirror of
https://github.com/corda/corda.git
synced 2025-06-01 23:20:54 +00:00
NOTICK: Fix IRSDemo code to wait for a response when updating day (#6329)
This commit is contained in:
parent
58af87c988
commit
48ed9dbc6b
@ -27,6 +27,7 @@ object UpdateBusinessDayFlow {
|
|||||||
override fun call() {
|
override fun call() {
|
||||||
val message = otherPartySession.receive<UpdateBusinessDayMessage>().unwrap { it }
|
val message = otherPartySession.receive<UpdateBusinessDayMessage>().unwrap { it }
|
||||||
(serviceHub.clock as DemoClock).updateDate(message.date)
|
(serviceHub.clock as DemoClock).updateDate(message.date)
|
||||||
|
otherPartySession.send(true) // Let's Broadcast know we've updated the clock
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -64,7 +65,7 @@ object UpdateBusinessDayFlow {
|
|||||||
|
|
||||||
@Suspendable
|
@Suspendable
|
||||||
private fun doNextRecipient(recipient: Party) {
|
private fun doNextRecipient(recipient: Party) {
|
||||||
initiateFlow(recipient).send(UpdateBusinessDayMessage(date))
|
initiateFlow(recipient).sendAndReceive<Boolean>(UpdateBusinessDayMessage(date))
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
Loading…
x
Reference in New Issue
Block a user