From 96b46782c1e1958e9919b7ab427546c6f4f1dc9c Mon Sep 17 00:00:00 2001
From: Kyriakos Tharrouniatis <kyriakos.tharrouniatis@r3.com>
Date: Tue, 18 Feb 2020 13:57:57 +0000
Subject: [PATCH] Move CustomSafeSubscriber outside test methods

---
 .../kotlin/net/corda/node/utilities/ObservablesTests.kt     | 6 ++----
 1 file changed, 2 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 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<T>(actual: Subscriber<in T>): SafeSubscriber<T>(actual)
-
         var heartBeat = 0
         val customSafeSubscriber = CustomSafeSubscriber(
             Subscribers.create<Int> {
@@ -406,8 +404,6 @@ class ObservablesTests {
 
     @Test
     fun `test flowSafeSubscribe strictMode = false will not replace SafeSubscriber subclass`() {
-        class CustomSafeSubscriber<T>(actual: Subscriber<in T>): SafeSubscriber<T>(actual)
-
         var heartBeat = 0
         val customSafeSubscriber = CustomSafeSubscriber(
             Subscribers.create<Int> {
@@ -568,4 +564,6 @@ class ObservablesTests {
 
         subscription3.unsubscribe()
     }
+
+    class CustomSafeSubscriber<T>(actual: Subscriber<in T>): SafeSubscriber<T>(actual)
 }
\ No newline at end of file