import java.io.ByteArrayInputStream;
import java.io.InputStream;
import java.util.Collection;
+import java.util.function.Consumer;
import org.simantics.db.Resource;
import org.simantics.db.Session;
import org.simantics.db.procore.cluster.ClusterSmall;
import org.simantics.db.service.SerialisationSupport;
import org.simantics.utils.DataContainer;
-import org.simantics.utils.datastructures.Callback;
public class QuerySupportImpl implements QuerySupport {
@Override
public void requestCluster(ReadGraphImpl graph, final long clusterId, final Runnable r) {
- class CallbackAdapter implements Callback<DatabaseException> {
+ class CallbackAdapter implements Consumer<DatabaseException> {
final Runnable r;
CallbackAdapter(final Runnable r) {
this.r = r;
}
@Override
- public void run(DatabaseException e) {
+ public void accept(DatabaseException e) {
if (null != e)
e.printStackTrace();
else
if(subject < 0) {
- SessionImplSocket.loadVirtualStatements(virtualGraphServerSupport, graph, subject, predicate, new Callback<ReadGraphImpl>() {
-
- @Override
- public void run(ReadGraphImpl parameter) {
- }
-
- });
+ SessionImplSocket.loadVirtualStatements(virtualGraphServerSupport, graph, subject, predicate, g -> {});
} else {
if(cluster.hasVirtual() && virtualGraphServerSupport.virtuals.contains(subject) && !SessionImplSocket.areVirtualStatementsLoaded(virtualGraphServerSupport, subject, predicate)) {
- SessionImplSocket.loadVirtualStatements(virtualGraphServerSupport, graph, subject, predicate, new Callback<ReadGraphImpl>() {
-
- @Override
- public void run(ReadGraphImpl parameter) {
- }
-
- });
+ SessionImplSocket.loadVirtualStatements(virtualGraphServerSupport, graph, subject, predicate, g -> {});
} else {
if(cluster.hasVirtual() && virtualGraphServerSupport.virtuals.contains(subject) && !SessionImplSocket.areVirtualStatementsLoaded(virtualGraphServerSupport, subject, predicate)) {
- SessionImplSocket.loadVirtualStatements(virtualGraphServerSupport, graph, subject, predicate, new Callback<ReadGraphImpl>() {
-
- @Override
- public void run(ReadGraphImpl parameter) {
- }
-
- });
+ SessionImplSocket.loadVirtualStatements(virtualGraphServerSupport, graph, subject, predicate, g -> {});
} else {
if(subject < 0) {
- SessionImplSocket.loadVirtualStatements(virtualGraphServerSupport, graph, subject, new Callback<ReadGraphImpl>() {
-
- @Override
- public void run(ReadGraphImpl parameter) {
- }
-
- });
+ SessionImplSocket.loadVirtualStatements(virtualGraphServerSupport, graph, subject, g -> {});
} else {
if(cluster.hasVirtual() && virtualGraphServerSupport.virtuals.contains(subject) && !SessionImplSocket.areVirtualStatementsLoaded(virtualGraphServerSupport, subject)) {
- SessionImplSocket.loadVirtualStatements(virtualGraphServerSupport, graph, subject, new Callback<ReadGraphImpl>() {
-
- @Override
- public void run(ReadGraphImpl parameter) {
- }
-
- });
+ SessionImplSocket.loadVirtualStatements(virtualGraphServerSupport, graph, subject, g -> {});
} else {
if(cluster.hasVirtual() && virtualGraphServerSupport.virtuals.contains(subject) && !SessionImplSocket.areVirtualStatementsLoaded(virtualGraphServerSupport, subject)) {
- SessionImplSocket.loadVirtualStatements(virtualGraphServerSupport, graph, subject, new Callback<ReadGraphImpl>() {
-
- @Override
- public void run(ReadGraphImpl parameter) {
- }
-
- });
+ SessionImplSocket.loadVirtualStatements(virtualGraphServerSupport, graph, subject, g -> {});
} else {