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 16a0ca3255..52ad90aba7 100644 --- a/node/src/test/kotlin/net/corda/node/utilities/ObservablesTests.kt +++ b/node/src/test/kotlin/net/corda/node/utilities/ObservablesTests.kt @@ -387,8 +387,6 @@ class ObservablesTests { @Test fun `test flowSafeSubscribe strictMode = true replaces SafeSubscriber subclass`() { - class CustomSafeSubscriber(actual: Subscriber): SafeSubscriber(actual) - var heartBeat = 0 val customSafeSubscriber = CustomSafeSubscriber( Subscribers.create { @@ -406,8 +404,6 @@ class ObservablesTests { @Test fun `test flowSafeSubscribe strictMode = false will not replace SafeSubscriber subclass`() { - class CustomSafeSubscriber(actual: Subscriber): SafeSubscriber(actual) - var heartBeat = 0 val customSafeSubscriber = CustomSafeSubscriber( Subscribers.create { @@ -568,4 +564,6 @@ class ObservablesTests { subscription3.unsubscribe() } + + class CustomSafeSubscriber(actual: Subscriber): SafeSubscriber(actual) } \ No newline at end of file