Skip to content

Commit f5c29b1

Browse files
committed
Refactor Scheduler
1 parent 3569c68 commit f5c29b1

File tree

1 file changed

+6
-8
lines changed
  • src/common/src/main/java/org/smoothbuild/common/schedule

1 file changed

+6
-8
lines changed

src/common/src/main/java/org/smoothbuild/common/schedule/Scheduler.java

Lines changed: 6 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,6 @@
1313
import com.google.inject.Key;
1414
import jakarta.inject.Inject;
1515
import jakarta.inject.Singleton;
16-
import java.util.function.Supplier;
1716
import org.smoothbuild.common.collect.List;
1817
import org.smoothbuild.common.collect.Maybe;
1918
import org.smoothbuild.common.concurrent.MutablePromise;
@@ -258,20 +257,19 @@ private static List<Promise<? extends Maybe<?>>> concatenate(
258257

259258
private class Execution<R> implements Runnable {
260259
private final MutablePromise<Maybe<R>> result;
261-
private final Supplier<Output<R>> taskResultSupplier;
260+
private final Task0<R> task;
262261

263-
private Execution(Supplier<Output<R>> taskResultSupplier) {
264-
this.taskResultSupplier = taskResultSupplier;
262+
private Execution(Task0<R> task) {
263+
this.task = task;
265264
this.result = promise();
266265
}
267266

268267
@Override
269268
public void run() {
270269
try {
271-
var taskResult = taskResultSupplier.get();
272-
var report = taskResult.report();
273-
reporter.submit(report);
274-
taskResult.result().addConsumer(result);
270+
var output = task.execute();
271+
reporter.submit(output.report());
272+
output.result().addConsumer(result);
275273
} catch (Exception e) {
276274
var fatal = fatal("Task execution failed with exception:", e);
277275
reporter.submit(report(LABEL, list(fatal)));

0 commit comments

Comments
 (0)