From 6d5e08b44e60cb6dade5142d146b7b078095d61a Mon Sep 17 00:00:00 2001
From: Andras Slemmer <andras.slemmer@r3cev.com>
Date: Tue, 3 Apr 2018 11:43:17 +0100
Subject: [PATCH] CORDA-1295: Clean up client->observable association on
 observable finish

---
 .../main/kotlin/net/corda/node/services/messaging/RPCServer.kt   | 1 +
 1 file changed, 1 insertion(+)

diff --git a/node/src/main/kotlin/net/corda/node/services/messaging/RPCServer.kt b/node/src/main/kotlin/net/corda/node/services/messaging/RPCServer.kt
index e70f80d39d..d3717de4ec 100644
--- a/node/src/main/kotlin/net/corda/node/services/messaging/RPCServer.kt
+++ b/node/src/main/kotlin/net/corda/node/services/messaging/RPCServer.kt
@@ -525,6 +525,7 @@ object RpcServerObservableSerializer : Serializer<Observable<*>>() {
                             }
 
                             override fun onCompleted() {
+                                observableContext.clientAddressToObservables.remove(observableContext.clientAddress, observableId)
                             }
                         }
                 )