- AsyncReadEntry.computeForEach(graph, r, entry, procedure_);
- if(listenerEntry != null) cache.primeListenerEntry(listenerEntry, entry.getResult());
+ Object result = AsyncReadEntry.computeForEach(graph, r, entry, procedure_, needsToBlock);
+ if(listenerEntry != null) cache.primeListenerEntry(listenerEntry, entry.getResult());
+ return result;
+ }
+ }
+
+
+ private AsyncReadEntry peekAsyncReadEntry(AsyncRead<?> r) {
+ synchronized(asyncReadEntryMap) {
+ return (AsyncReadEntry) asyncReadEntryMap.get(r);