feat(core): move on development version of async-iterator

work on #9
bsorrentino · Jul 13, 2024 · 4d385b9 · 4d385b9
1 parent 5ebfa76
commit 4d385b9
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 7 deletions.
diff --git a/core-jdk8/pom.xml b/core-jdk8/pom.xml
@@ -27,7 +27,7 @@
     <dependency>
       <groupId>org.bsc.async</groupId>
       <artifactId>async-generator-jdk8</artifactId>
-      <version>1.0.0</version>
+      <version>2.0.0-SNAPSHOT</version>
     </dependency>
 
     <dependency>

diff --git a/core-jdk8/src/test/java/org/bsc/langgraph4j/AsyncTest.java b/core-jdk8/src/test/java/org/bsc/langgraph4j/AsyncTest.java
@@ -37,16 +37,16 @@ public Data<String> next() {
 
         it.forEachAsync( result::add ).thenAccept( t -> {
             System.out.println( "Finished");
-        });
+        }).join();
 
         for (var i : it) {
             result.add(i);
             System.out.println(i);
         }
         System.out.println( "Finished");
 
-        assertEquals( result.size(), myArray.length );
-        assertIterableEquals( result, listOf(myArray));
+        assertEquals(myArray.length, result.size() );
+        assertIterableEquals( listOf(myArray), result );
     }
     @Test
     public void asyncQueueTest() throws Exception {
@@ -61,11 +61,11 @@ public void asyncQueueTest() throws Exception {
 
         it.forEachAsync(result::add).thenAccept( (t) -> {
             System.out.println( "Finished");
-        });
+        }).join();
 
 
-        assertEquals(result.size(), 10);
-        assertIterableEquals(result, listOf("e0", "e1", "e2", "e3", "e4", "e5", "e6", "e7", "e8", "e9"));
+        assertEquals( 10, result.size());
+        assertIterableEquals(listOf("e0", "e1", "e2", "e3", "e4", "e5", "e6", "e7", "e8", "e9"), result);
 
     }