Multiple reader thread support for db client

[simantics/platform.git] / tests / org.simantics.db.tests / src / org / simantics / db / tests / api / request / misc / RequestQueuingTest.java

diff --git a/tests/org.simantics.db.tests/src/org/simantics/db/tests/api/request/misc/RequestQueuingTest.java b/tests/org.simantics.db.tests/src/org/simantics/db/tests/api/request/misc/RequestQueuingTest.java
index c17e35797c71cc3f7aa3190c0fff0923e14de5ef..188ab6db92f0419b195918adfced238f94664f99 100644 (file)
--- a/tests/org.simantics.db.tests/src/org/simantics/db/tests/api/request/misc/RequestQueuingTest.java
+++ b/tests/org.simantics.db.tests/src/org/simantics/db/tests/api/request/misc/RequestQueuingTest.java
@@ -17,6 +17,7 @@ import org.junit.Test;
 import org.simantics.db.AsyncReadGraph;
 import org.simantics.db.ReadGraph;
 import org.simantics.db.Session;
+import org.simantics.db.common.request.AsyncReadRequest;
 import org.simantics.db.exception.DatabaseException;
 import org.simantics.db.procedure.AsyncListener;
 import org.simantics.db.procedure.AsyncProcedure;
@@ -168,10 +169,10 @@ public class RequestQueuingTest extends ExistingDatabaseTest {
                
                Session session = getSession();
                
-               session.syncRequest(new Read<Object>() {
+               session.syncRequest(new AsyncReadRequest() {
 
                        @Override
-                       public Object perform(ReadGraph graph) throws DatabaseException {
+                       public void run(AsyncReadGraph graph) {
 
                                A a = new A();
                                B b = new B();
@@ -182,8 +183,6 @@ public class RequestQueuingTest extends ExistingDatabaseTest {
                                for(int i=0;i<LOOPS;i++) graph.asyncRequest(b, new C());
                                for(int i=0;i<LOOPS;i++) graph.asyncRequest(b2, new C());
 
-                               return null;
-
                        }
 
                });