]> gerrit.simantics Code Review - simantics/platform.git/blobdiff - tests/org.simantics.db.tests/src/org/simantics/db/tests/api/request/misc/RequestParentTest4.java
Multiple reader thread support for db client
[simantics/platform.git] / tests / org.simantics.db.tests / src / org / simantics / db / tests / api / request / misc / RequestParentTest4.java
index 7ae1a8491bb7188ee2649fc42d6b4674d8171ab7..8bdad204ba698caf8110f0f34f411d8d039f136b 100644 (file)
@@ -20,8 +20,8 @@ import org.simantics.db.Session;
 import org.simantics.db.exception.DatabaseException;
 import org.simantics.db.impl.query.CacheEntry;
 import org.simantics.db.impl.service.QueryDebug;
-import org.simantics.db.procedure.AsyncMultiListener;
-import org.simantics.db.procedure.AsyncMultiProcedure;
+import org.simantics.db.procedure.SyncMultiListener;
+import org.simantics.db.procedure.SyncMultiProcedure;
 import org.simantics.db.request.MultiRead;
 import org.simantics.db.testing.annotation.Fails;
 import org.simantics.db.testing.base.ExistingDatabaseTest;
@@ -39,7 +39,7 @@ public class RequestParentTest4 extends ExistingDatabaseTest {
         class Request implements MultiRead<Object> {
 
             @Override
-            public void perform(ReadGraph graph, AsyncMultiProcedure<Object> callback) throws DatabaseException {
+            public void perform(ReadGraph graph, SyncMultiProcedure<Object> callback) throws DatabaseException {
                 callback.execute(graph, new Object());
                 callback.finished(graph);
             }
@@ -49,15 +49,15 @@ public class RequestParentTest4 extends ExistingDatabaseTest {
         final Request request1 = new Request();
         final Request request2 = new Request();
         
-        session.syncRequest(request1, new AsyncMultiListener<Object>() {
+        session.syncRequest(request1, new SyncMultiListener<Object>() {
 
             @Override
-            public void exception(AsyncReadGraph graph, Throwable t) {
+            public void exception(ReadGraph graph, Throwable t) {
             }
 
             @Override
-            public void execute(AsyncReadGraph graph, Object result) {
-                graph.asyncRequest(request2);
+            public void execute(ReadGraph graph, Object result) throws DatabaseException {
+                graph.syncRequest(request2);
             }
 
             @Override
@@ -66,7 +66,7 @@ public class RequestParentTest4 extends ExistingDatabaseTest {
             }
 
             @Override
-            public void finished(AsyncReadGraph graph) {
+            public void finished(ReadGraph graph) {
             }
 
         });