cleanup testing

neurallayer · Aug 25, 2023 · 1e52394 · 1e52394
1 parent 516017a
commit 1e52394
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 43 deletions.
diff --git a/roboquant-avro/pom.xml b/roboquant-avro/pom.xml
@@ -56,17 +56,12 @@
             <version>1.1.10.1</version>
         </dependency>
 
-        <!-- Fix Issues -->
+        <!-- required for schema parsing -->
         <dependency>
             <groupId>com.fasterxml.jackson.core</groupId>
             <artifactId>jackson-core</artifactId>
             <version>2.15.2</version>
         </dependency>
-        <dependency>
-            <groupId>com.fasterxml.jackson.core</groupId>
-            <artifactId>jackson-databind</artifactId>
-            <version>2.15.2</version>
-        </dependency>
     </dependencies>
 
 </project>
diff --git a/roboquant-avro/src/test/kotlin/org/roboquant/avro/AvroFeedTest.kt b/roboquant-avro/src/test/kotlin/org/roboquant/avro/AvroFeedTest.kt
@@ -16,7 +16,7 @@
 
 package org.roboquant.avro
 
-import kotlinx.coroutines.runBlocking
+import kotlinx.coroutines.*
 import org.junit.jupiter.api.MethodOrderer.Alphanumeric
 import org.junit.jupiter.api.TestMethodOrder
 import org.junit.jupiter.api.assertDoesNotThrow
@@ -49,6 +49,18 @@ class AvroFeedTest {
 
     }
 
+
+    private fun play(feed: Feed, timeframe: Timeframe = Timeframe.INFINITE): EventChannel {
+        val channel = EventChannel(timeframe = timeframe)
+
+        CoroutineScope(Dispatchers.IO + Job()).launch {
+            feed.play(channel)
+            channel.close()
+        }
+        return channel
+    }
+
+
     internal companion object {
 
         @TempDir

diff --git a/roboquant-avro/src/test/kotlin/org/roboquant/avro/TestFeedTest.kt b/roboquant-avro/src/test/kotlin/org/roboquant/avro/TestFeedTest.kt