Changeset 105 for java/main/src/main/java/com/framsticks/dumping
- Timestamp:
- 09/10/13 21:11:41 (11 years ago)
- Location:
- java/main/src/main/java/com/framsticks/dumping
- Files:
-
- 2 edited
Legend:
- Unmodified
- Added
- Removed
-
java/main/src/main/java/com/framsticks/dumping/LoadStream.java
r100 r105 2 2 3 3 import com.framsticks.communication.File; 4 import com.framsticks.core.TreeOperations;5 import com.framsticks.core.Path;6 4 import com.framsticks.params.ListSource; 7 import com.framsticks.core.Tree; 5 import com.framsticks.structure.Path; 6 import com.framsticks.structure.Tree; 7 import com.framsticks.structure.TreeOperations; 8 8 import com.framsticks.util.*; 9 import com.framsticks.util.dispatching.Future ;9 import com.framsticks.util.dispatching.FutureHandler; 10 10 import com.framsticks.util.lang.Pair; 11 11 import com.framsticks.util.lang.Strings; … … 28 28 protected final Path mountPath; 29 29 protected final BufferedReader stream; 30 protected final Future <Path> future;30 protected final FutureHandler<Path> future; 31 31 protected final Stopwatch stopwatch = new Stopwatch(); 32 32 33 33 34 public LoadStream(Path mountPath, BufferedReader stream, Tree tree, Future <Path> future) {34 public LoadStream(Path mountPath, BufferedReader stream, Tree tree, FutureHandler<Path> future) { 35 35 this.tree = tree; 36 36 this.mountPath = mountPath; -
java/main/src/main/java/com/framsticks/dumping/SaveStream.java
r102 r105 1 1 package com.framsticks.dumping; 2 2 3 import static com.framsticks.core.TreeOperations.*;4 3 import static com.framsticks.params.AccessOperations.*; 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; … … 11 8 import com.framsticks.params.Sink; 12 9 import com.framsticks.parsers.Savers; 13 import com.framsticks.core.Tree; 10 import com.framsticks.structure.Node; 11 import com.framsticks.structure.Path; 12 import com.framsticks.structure.Tree; 14 13 import com.framsticks.util.*; 15 14 import com.framsticks.util.dispatching.Dispatching; 16 import com.framsticks.util.dispatching.Future ;15 import com.framsticks.util.dispatching.FutureHandler; 17 16 18 17 import org.apache.logging.log4j.Logger; … … 22 21 import java.util.HashSet; 23 22 import java.util.Set; 23 24 import static com.framsticks.structure.TreeOperations.*; 24 25 import static com.framsticks.util.lang.Containers.filterInstanceof; 25 26 … … 33 34 protected final Sink sink; 34 35 protected final Tree tree; 35 protected final Future <Void> future;36 protected final FutureHandler<Void> future; 36 37 protected final Stopwatch stopwatch = new Stopwatch(); 37 38 protected final Set<FramsClass> storedInfo = new HashSet<FramsClass>(); … … 39 40 private int dispatched = 0; 40 41 41 public SaveStream(Sink sink, Tree tree, Path root, Future <Void> future) {42 public SaveStream(Sink sink, Tree tree, Path root, FutureHandler<Void> future) { 42 43 assert Dispatching.isThreadSafe(); 43 44 this.sink = sink;
Note: See TracChangeset
for help on using the changeset viewer.