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;
final ArrayList<Resource> resources = new ArrayList<Resource>();
final Resource root = SyncAsyncSyncUtils.createNames(session, names, resources);
- session.syncRequest(new TestReadRequest() {
+ session.syncRequest(new TestAsyncReadRequest() {
@Override
- public void run(ReadGraph graph) {
+ public void run(AsyncReadGraph graph) {
Layer0 b = Layer0.getInstance(graph);
graph.forObjectSet(root, b.ConsistsOf, new SyncSetListener<Resource>() {
@Override
public void add(ReadGraph graph, final Resource resource) throws DatabaseException {
- graph.asyncRequest(new TestReadRequest() {
+ graph.syncRequest(new TestAsyncReadRequest() {
@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>() {