- Timestamp:
- 09/10/13 21:11:41 (11 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
java/main/src/main/java/com/framsticks/remote/RecursiveFetcher.java
r100 r105 1 1 package com.framsticks.remote; 2 2 3 import static com.framsticks.core.TreeOperations.*;4 3 5 import com.framsticks.core.Node;6 import com.framsticks.core.Path;7 4 import com.framsticks.params.Access; 8 5 import com.framsticks.params.CompositeParam; 9 import com.framsticks.params.FramsClass; 10 import com.framsticks.core.Tree; 6 import com.framsticks.structure.Node; 7 import com.framsticks.structure.Path; 8 import com.framsticks.structure.Tree; 9 import com.framsticks.util.dispatching.FutureHandler; 11 10 import com.framsticks.util.dispatching.Future; 12 import com.framsticks.util.dispatching.FutureHandler;13 11 import com.framsticks.util.dispatching.ThrowExceptionHandler; 14 12 import com.framsticks.util.FramsticksException; … … 17 15 import org.apache.logging.log4j.Logger; 18 16 import org.apache.logging.log4j.LogManager; 17 18 import static com.framsticks.structure.TreeOperations.*; 19 19 import static com.framsticks.util.lang.Containers.filterInstanceof; 20 20 import com.framsticks.util.dispatching.RunAt; … … 28 28 29 29 protected final Tree tree; 30 protected final Future <Void> future;30 protected final FutureHandler<Void> future; 31 31 protected int dispatched; 32 32 protected final Stopwatch stopwatch = new Stopwatch(); 33 33 34 public RecursiveFetcher(Tree tree, final Path path, Future <Void> future) {34 public RecursiveFetcher(Tree tree, final Path path, FutureHandler<Void> future) { 35 35 this.tree = tree; 36 36 this.future = future; … … 51 51 } else { 52 52 Access access = bindAccess(path); 53 FramsClass framsClass = access.getFramsClass();54 assert framsClass != null;55 53 for (CompositeParam p : filterInstanceof(access.getParams(), CompositeParam.class)) { 56 54 Object child = access.get(p, Object.class); … … 67 65 } 68 66 ++dispatched; 69 tree.get(childPath, new Future Handler<Path>(Logging.logger(log, "resolve", RecursiveFetcher.this)) {67 tree.get(childPath, new Future<Path>(Logging.logger(log, "resolve", RecursiveFetcher.this)) { 70 68 @Override 71 69 protected void result(Path result) { … … 83 81 84 82 protected void fetch(final Path path) { 85 tree.get(path, new Future <Path>() {83 tree.get(path, new FutureHandler<Path>() { 86 84 87 85 @Override
Note: See TracChangeset
for help on using the changeset viewer.