fix test

teletha · Apr 21, 2024 · c35f9e0 · c35f9e0
1 parent 21979c3
commit c35f9e0
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/src/test/java/typewriter/api/AccumulableTestSet.java b/src/test/java/typewriter/api/AccumulableTestSet.java
@@ -15,6 +15,7 @@
 
 import kiss.Signal;
 import typewriter.api.model.DerivableModel;
+import typewriter.rdb.RDB;
 
 public interface AccumulableTestSet extends Testable {
 
@@ -97,7 +98,7 @@ default void avgDistinct() {
         Person model2 = new Person("B", 10);
         Person model3 = new Person("C", 30);
 
-        QueryExecutor<Person, Signal<Person>, ?, ?> dao = createEmptyDB(Person.class);
+        RDB<Person> dao = createEmptyDB(Person.class);
         dao.update(model1);
         dao.update(model2);
         dao.update(model3);
@@ -114,7 +115,7 @@ default void avgFrame() {
         Person model4 = new Person("C", 40);
         Person model5 = new Person("C", 50);
 
-        QueryExecutor<Person, Signal<Person>, ?, ?> dao = createEmptyDB(Person.class);
+        RDB<Person> dao = createEmptyDB(Person.class);
         dao.updateAll(model1, model2, model3, model4, model5);
 
         List<Double> calculated = dao.avg(Person::getAge, o -> o.frame(-2, 0)).waitForTerminate().toList();
@@ -142,7 +143,7 @@ default void avgOrderBy() {
         Person model4 = new Person("C", 40);
         Person model5 = new Person("C", 50);
 
-        QueryExecutor<Person, Signal<Person>, ?, ?> dao = createEmptyDB(Person.class);
+        RDB<Person> dao = createEmptyDB(Person.class);
         dao.updateAll(model1, model2, model3, model4, model5);
 
         List<Double> calculated = dao.avg(Person::getAge, o -> o.orderBy(Person::getAge)).toList();