com.facebook.buck.core.build.engine.impl

Class BuildRulePipelinesRunner

java.lang.Object

com.facebook.buck.core.build.engine.impl.BuildRulePipelinesRunner

public class BuildRulePipelinesRunner
extends Object

Constructs build rule pipelines for a single build.

Constructor Summary

Constructors

Constructor and Description
BuildRulePipelinesRunner()

Method Summary

Modifier and Type	Method and Description
<T extends RulePipelineState> void	addRule(SupportsPipelining<T> rule, java.util.function.Function<T,RunnableWithFuture<Optional<BuildResult>>> ruleStepRunnerFactory) Gives the factory a way to construct a RunnableWithFuture to build the given rule.
com.google.common.util.concurrent.ListenableFuture<Optional<BuildResult>>	getFuture(SupportsPipelining<?> rule)
void	removeRule(SupportsPipelining<?> rule) Removes a rule from pipeline eligibility.
boolean	runningPipelinesContainRule(SupportsPipelining<?> rule)
<T extends RulePipelineState> com.google.common.util.concurrent.ListenableFuture<Optional<BuildResult>>	runPipelineStartingAt(BuildContext context, SupportsPipelining<T> rootRule, ExecutorService executor)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BuildRulePipelinesRunner

public BuildRulePipelinesRunner()

Method Detail

addRule

public <T extends RulePipelineState> void addRule(SupportsPipelining<T> rule,
                                                  java.util.function.Function<T,RunnableWithFuture<Optional<BuildResult>>> ruleStepRunnerFactory)

Gives the factory a way to construct a RunnableWithFuture to build the given rule.

removeRule

public void removeRule(SupportsPipelining<?> rule)

Removes a rule from pipeline eligibility. If a pipeline is already running the rule, waits for it to complete before returning.

runningPipelinesContainRule

public boolean runningPipelinesContainRule(SupportsPipelining<?> rule)

getFuture

public com.google.common.util.concurrent.ListenableFuture<Optional<BuildResult>> getFuture(SupportsPipelining<?> rule)

runPipelineStartingAt

public <T extends RulePipelineState> com.google.common.util.concurrent.ListenableFuture<Optional<BuildResult>> runPipelineStartingAt(BuildContext context,
                                                                                                                                     SupportsPipelining<T> rootRule,
                                                                                                                                     ExecutorService executor)