Multiple reader thread support for db client

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

diff --git a/tests/org.simantics.db.tests/src/org/simantics/db/tests/api/request/misc/SyncAsyncSyncTest5.java b/tests/org.simantics.db.tests/src/org/simantics/db/tests/api/request/misc/SyncAsyncSyncTest5.java
index 29b682119d8816620cd08a8b354f22002780ccb6..7e50d9a0866fb947c06c9e81d833f1b5a33516cb 100644 (file)
--- a/tests/org.simantics.db.tests/src/org/simantics/db/tests/api/request/misc/SyncAsyncSyncTest5.java
+++ b/tests/org.simantics.db.tests/src/org/simantics/db/tests/api/request/misc/SyncAsyncSyncTest5.java
@@ -15,6 +15,7 @@ import java.util.ArrayList;
 import java.util.concurrent.ConcurrentSkipListSet;
 
 import org.junit.Test;
 import java.util.concurrent.ConcurrentSkipListSet;
 
 import org.junit.Test;

+import org.simantics.db.AsyncReadGraph;

 import org.simantics.db.ReadGraph;
 import org.simantics.db.Resource;
 import org.simantics.db.Session;
 import org.simantics.db.ReadGraph;
 import org.simantics.db.Resource;
 import org.simantics.db.Session;


@@ -34,10 +35,10 @@ public class SyncAsyncSyncTest5 extends ExistingDatabaseTest {
                final ArrayList<Resource> resources = new ArrayList<Resource>();
                final Resource root = SyncAsyncSyncUtils.createNames(session, names, resources);
 
                final ArrayList<Resource> resources = new ArrayList<Resource>();
                final Resource root = SyncAsyncSyncUtils.createNames(session, names, resources);
 

-        session.syncRequest(new TestReadRequest() {
+        session.syncRequest(new TestAsyncReadRequest() {

 
             @Override
 
             @Override

-            public void run(ReadGraph graph) {
+            public void run(AsyncReadGraph graph) {

                 
                 Layer0 b = Layer0.getInstance(graph);
                 graph.forObjectSet(root, b.ConsistsOf, new SyncSetListener<Resource>() {
                 
                 Layer0 b = Layer0.getInstance(graph);
                 graph.forObjectSet(root, b.ConsistsOf, new SyncSetListener<Resource>() {


@@ -45,10 +46,10 @@ public class SyncAsyncSyncTest5 extends ExistingDatabaseTest {
                     @Override
                     public void add(ReadGraph graph, final Resource resource) throws DatabaseException {
 
                     @Override
                     public void add(ReadGraph graph, final Resource resource) throws DatabaseException {
 

-                        graph.asyncRequest(new TestReadRequest() {
+                        graph.syncRequest(new TestAsyncReadRequest() {

 
                             @Override
 
                             @Override

-                            public void run(ReadGraph graph) throws DatabaseException {
+                            public void run(AsyncReadGraph graph) throws DatabaseException {

                                 Layer0 b = Layer0.getInstance(graph);
                                 graph.forObjectSet(resource, b.HasName, new SyncSetListener<Resource>() {
                                     
                                 Layer0 b = Layer0.getInstance(graph);
                                 graph.forObjectSet(resource, b.HasName, new SyncSetListener<Resource>() {