ArrayDeque FlowLogic references were not being removed on flow termination. (#353)

2025-02-20 09:26:41 +00:00 · 2017-03-14 15:25:34 +00:00 · 2017-03-14 15:25:34 +00:00 · 18e4620928
commit 18e4620928
parent 81dcec579e
1 changed files with 1 additions and 0 deletions
--- a/node/src/main/kotlin/net/corda/node/utilities/ANSIProgressObserver.kt
+++ b/node/src/main/kotlin/net/corda/node/utilities/ANSIProgressObserver.kt
@ -40,6 +40,7 @@ class ANSIProgressObserver(val smm: StateMachineManager) {

    private fun removeFlowLogic(flowLogic: FlowLogic<*>) {
        state.locked {
+            pending.remove(flowLogic)
            if (currentlyRendering == flowLogic) {
                wireUpProgressRendering()
            }