Skip to content

Commit

Permalink
Fixing a bunch of RawType usages and minor improvments in simplying c…
Browse files Browse the repository at this point in the history
…allback
  • Loading branch information
anuchandy committed Aug 11, 2016
1 parent c039c6e commit 9980d1f
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,14 @@
*/
public abstract class TaskGroupBase<T, U extends TaskItem<T>>
implements TaskGroup<T, U> {
/**
* Stores the tasks in this group and their dependency information.
*/
private DAGraph<U, DAGNode<U>> dag;
/**
* ServiceCall instance that aggregate a set of ServiceCalls each associated with
* the task in this group.
*/
private ParallelServiceCall parallelServiceCall;

/**
Expand Down Expand Up @@ -87,7 +94,7 @@ public T taskResult(String taskId) {
private void executeReadyTasksAsync(final ServiceCallback<T> callback) {
DAGNode<U> nextNode = dag.getNext();
while (nextNode != null) {
ServiceCall serviceCall = nextNode.data().executeAsync(taskCallback(nextNode, callback));
ServiceCall<T> serviceCall = nextNode.data().executeAsync(taskCallback(nextNode, callback));
this.parallelServiceCall.addCall(serviceCall);
nextNode = dag.getNext();
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -38,5 +38,5 @@ public interface TaskItem<U> {
* @param callback callback to call on success or failure
* @return the handle of the REST call
*/
ServiceCall executeAsync(ServiceCallback<U> callback);
ServiceCall<U> executeAsync(ServiceCallback<U> callback);
}

0 comments on commit 9980d1f

Please sign in to comment.