refactoring test

teletha · Nov 12, 2024 · 2df3a44 · 2df3a44
1 parent dd28a6a
commit 2df3a44
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 15 deletions.
diff --git a/src/test/java/kiss/signal/FisrtTest.java b/src/test/java/kiss/signal/FisrtTest.java
@@ -14,7 +14,6 @@
 
 import org.junit.jupiter.api.Test;
 
-import antibug.Chronus;
 import kiss.I;
 
 class FisrtTest extends SignalTester {
@@ -71,19 +70,17 @@ void dontStopFollowingSignalImmediately() {
         assert countingItemsOnSourceSignal.size() == 1;
     }
 
-    Chronus chronus = new Chronus();
-
     @Test
     void dontStopFollowingAsyncSignalImmediately() {
         List<Integer> countingItemsOnSourceSignal = new ArrayList();
 
         List<Integer> result = I.signal(1, 2, 3)
                 .effect(countingItemsOnSourceSignal::add)
                 .first()
-                .flatMap(v -> I.signal(v * 10, v * 100).delay(20, ms, chronus))
+                .flatMap(v -> I.signal(v * 10, v * 100).delay(20, ms, scheduler))
                 .toList();
 
-        chronus.await();
+        scheduler.await();
         assert result.size() == 2;
         assert result.get(0) == 10;
         assert result.get(1) == 100;

diff --git a/src/test/java/kiss/signal/WaitTest.java b/src/test/java/kiss/signal/WaitTest.java
@@ -11,17 +11,12 @@
 
 import org.junit.jupiter.api.Test;
 
-import antibug.Chronus;
-
 class WaitTest extends SignalTester {
 
-    Chronus chrnous = new Chronus();
-
     @Test
     void waitForTerminate() {
-        monitor(signal -> signal.startWith(1, 2).delay(500, ms, chrnous).take(2).waitForTerminate());
+        monitor(signal -> signal.startWith(1, 2).delay(20, ms).take(2).waitForTerminate());
 
-        chrnous.await();
         assert main.value(1, 2);
         assert main.isCompleted();
         assert main.isNotError();
@@ -30,9 +25,8 @@ void waitForTerminate() {
 
     @Test
     void waitForTerminateByError() {
-        monitor(signal -> signal.startWith(1, 2).map(errorFunction()).delay(50, ms, chrnous).waitForTerminate());
+        monitor(signal -> signal.startWith(1, 2).map(errorFunction()).delay(20, ms).waitForTerminate());
 
-        chrnous.await();
         assert main.value();
         assert main.isNotCompleted();
         assert main.isError();
@@ -41,9 +35,8 @@ void waitForTerminateByError() {
 
     @Test
     void waitForTerminateByDispose() {
-        monitor(signal -> signal.startWith(1).delay(50, ms, chrnous).effectOnce(main::dispose).waitForTerminate());
+        monitor(signal -> signal.startWith(1).delay(20, ms).effectOnce(main::dispose).waitForTerminate());
 
-        chrnous.await();
         assert main.isNotCompleted();
         assert main.isNotError();
         assert main.isDisposed();