First changes

[simantics/platform.git] / bundles / org.simantics.db.impl / src / org / simantics / db / impl / query / AsyncReadEntry.java

diff --git a/bundles/org.simantics.db.impl/src/org/simantics/db/impl/query/AsyncReadEntry.java b/bundles/org.simantics.db.impl/src/org/simantics/db/impl/query/AsyncReadEntry.java
index a9726a75d6ac4eb5df323625ffd19da9369bcb9b..96e2fc15800d978d395631d8422d968e92adc715 100644 (file)
--- a/bundles/org.simantics.db.impl/src/org/simantics/db/impl/query/AsyncReadEntry.java
+++ b/bundles/org.simantics.db.impl/src/org/simantics/db/impl/query/AsyncReadEntry.java
@@ -126,7 +126,7 @@ final public class AsyncReadEntry<T> extends CacheEntryBase {
 
                        @Override
                        public void removeEntry(QueryProcessor qp) {
-                       qp.asyncReadMap.remove(request);
+                       qp.cache.asyncReadMap.remove(request);
                        }
 
                        @Override
@@ -145,8 +145,7 @@ final public class AsyncReadEntry<T> extends CacheEntryBase {
         
     }
 
-       @SuppressWarnings("unchecked")
-       public void performFromCache(ReadGraphImpl graph, Object provider, Object procedure) {
+       public Object performFromCache(ReadGraphImpl graph, Object provider, Object procedure) {
                
         AsyncProcedure<T> proc = (AsyncProcedure<T>)procedure;
 
@@ -168,6 +167,8 @@ final public class AsyncReadEntry<T> extends CacheEntryBase {
             
         }
                
+           return getResult();
+           
        }
 
        @Override