X-Git-Url: https://gerrit.simantics.org/r/gitweb?p=simantics%2Fplatform.git;a=blobdiff_plain;f=tests%2Forg.simantics.db.tests%2Fsrc%2Forg%2Fsimantics%2Fdb%2Ftests%2Fapi%2FreadGraph%2FforObjectSet%2FForObjectSetTest1.java;fp=tests%2Forg.simantics.db.tests%2Fsrc%2Forg%2Fsimantics%2Fdb%2Ftests%2Fapi%2FreadGraph%2FforObjectSet%2FForObjectSetTest1.java;h=dc492e20cfa1af451cd2d2cc3808806f87c3239d;hp=1a6a3a0b44a01604c301b73b6f899af061dcd527;hb=0d9b90834ce56b292c00b1a39850ed842c3e4d42;hpb=e5db6157fd8722c946613d4e46d7aaf6bfa92609 diff --git a/tests/org.simantics.db.tests/src/org/simantics/db/tests/api/readGraph/forObjectSet/ForObjectSetTest1.java b/tests/org.simantics.db.tests/src/org/simantics/db/tests/api/readGraph/forObjectSet/ForObjectSetTest1.java index 1a6a3a0b4..dc492e20c 100644 --- a/tests/org.simantics.db.tests/src/org/simantics/db/tests/api/readGraph/forObjectSet/ForObjectSetTest1.java +++ b/tests/org.simantics.db.tests/src/org/simantics/db/tests/api/readGraph/forObjectSet/ForObjectSetTest1.java @@ -45,33 +45,43 @@ public class ForObjectSetTest1 extends ExistingDatabaseTest { graph.claim(relation, b.SubrelationOf, b.IsRelatedTo); graph.claim(relation, b.InverseOf, relation); - graph.forObjectSet(graph.getRootLibrary(), relation, new AsyncSetListener() { - - @Override - public void add(AsyncReadGraph graph, Resource result) { - synchronized(this) { - adds++; - } - } - - @Override - public void remove(AsyncReadGraph graph, Resource result) { - synchronized(this) { - removes++; - } - } - - @Override - public void exception(AsyncReadGraph graph, Throwable t) { - exception = t; - } - - @Override - public boolean isDisposed() { - return false; - } - - }); + session.syncRequest(new TestAsyncReadRequest() { + + @Override + public void run(AsyncReadGraph graph) throws Throwable { + + graph.forObjectSet(graph.getRootLibrary(), relation, new AsyncSetListener() { + + @Override + public void add(AsyncReadGraph graph, Resource result) { + synchronized(this) { + adds++; + } + } + + @Override + public void remove(AsyncReadGraph graph, Resource result) { + synchronized(this) { + removes++; + } + } + + @Override + public void exception(AsyncReadGraph graph, Throwable t) { + exception = t; + } + + @Override + public boolean isDisposed() { + return false; + } + + }); + + } + + }); + } });