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