From 11d92f90d59264312f25a0070033347586e06d3a Mon Sep 17 00:00:00 2001
From: Kyriakos Tharrouniatis <kyriakos.tharrouniatis@r3.com>
Date: Mon, 17 Feb 2020 00:14:01 +0000
Subject: [PATCH] Splitting heartBeat to heartBeat1 and hearBeat2 for more
 clear asserting

---
 .../net/corda/node/utilities/ObservablesTests.kt       | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git a/node/src/test/kotlin/net/corda/node/utilities/ObservablesTests.kt b/node/src/test/kotlin/net/corda/node/utilities/ObservablesTests.kt
index 5b81a308b4..89b8f03d88 100644
--- a/node/src/test/kotlin/net/corda/node/utilities/ObservablesTests.kt
+++ b/node/src/test/kotlin/net/corda/node/utilities/ObservablesTests.kt
@@ -225,18 +225,19 @@ class ObservablesTests {
 
     @Test
     fun `FlowSafeSubject subscribes by default FlowSafeSubscribers, wrapped Observers will survive errors from onNext`() {
-        var heartBeat = 0
+        var heartBeat1 = 0
+        var heartBeat2 = 0
         val source = FlowSafeSubject(PublishSubject.create<Int>())
         source.subscribe { runNo ->
             // subscribes with a FlowSafeSubscriber
-            heartBeat++
+            heartBeat1++
             if (runNo == 1) {
                 throw IllegalStateException()
             }
         }
         source.subscribe { runNo ->
             // subscribes with a FlowSafeSubscriber
-            heartBeat++
+            heartBeat2++
             if (runNo == 2) {
                 throw IllegalStateException()
             }
@@ -249,7 +250,8 @@ class ObservablesTests {
             source.onNext(2) // first observer will run, second observer will run and throw
         }
         source.onNext(3) // both observers will run
-        assertEquals(5, heartBeat)
+        assertEquals(3, heartBeat1)
+        assertEquals(2, heartBeat2)
     }
 
     @Test