import org.gradle.tooling.internal.consumer.connection.ConsumerAction;
import org.gradle.tooling.internal.protocol.ResultHandlerVersion1;

/**
 * Implementations must be thread-safe.
 */
public interface AsyncConsumerActionExecutor {
    /**
     * Runs some operation asynchronously against a consumer connection. Notifies the provided handler when
     * complete. Note that the action may have completed by the time this method returns.
     *

    private final BuildAction<T> buildAction;
    private final AsyncConsumerActionExecutor connection;

    public DefaultBuildActionExecuter(BuildAction<T> buildAction, AsyncConsumerActionExecutor connection, ConnectionParameters parameters) {
        super(parameters);
        operationParamsBuilder.setEntryPoint("BuildActionExecuter API");

    private final PhasedBuildAction phasedBuildAction;
    private final AsyncConsumerActionExecutor connection;

    DefaultPhasedBuildActionExecuter(PhasedBuildAction phasedBuildAction, AsyncConsumerActionExecutor connection, ConnectionParameters parameters) {
        super(parameters);
        operationParamsBuilder.setEntryPoint("PhasedBuildActionExecuter API");

import java.util.Collections;

public class DefaultBuildLauncher extends AbstractLongRunningOperation<DefaultBuildLauncher> implements BuildLauncher {
    protected final AsyncConsumerActionExecutor connection;

    public DefaultBuildLauncher(AsyncConsumerActionExecutor connection, ConnectionParameters parameters) {
        super(parameters);
        operationParamsBuilder.setEntryPoint("BuildLauncher API");

LongRunningOperation -> OperationParamsBuilder: build()
OperationParamsBuilder --> LongRunningOperation: operation params
LongRunningOperation -> AsyncConsumerActionExecutor: run()
box "ConsumerActionExecutor chain"
	participant ProgressLogging
	participant LoggingInitializer
	participant LazyConsumer
end box
AsyncConsumerActionExecutor -> ProgressLogging: run()
ProgressLogging -> LoggingInitializer: run()
LoggingInitializer -> LazyConsumer: run()

public class DefaultModelBuilder<T> extends AbstractLongRunningOperation<DefaultModelBuilder<T>> implements ModelBuilder<T> {
    private final Class<T> modelType;
    private final AsyncConsumerActionExecutor connection;

    public DefaultModelBuilder(Class<T> modelType, AsyncConsumerActionExecutor connection, ConnectionParameters parameters) {
        super(parameters);
        this.modelType = modelType;
        this.connection = connection;

 */
package org.gradle.tooling.internal.consumer

import org.gradle.tooling.internal.consumer.async.AsyncConsumerActionExecutor
import org.gradle.tooling.model.GradleProject
import spock.lang.Specification

class DefaultProjectConnectionTest extends Specification {
    final AsyncConsumerActionExecutor protocolConnection = Mock()
    final ConnectionParameters parameters = Stub() {
        getProjectDir() >> new File("foo")

import java.util.List;

class DefaultProjectConnection implements ProjectConnection {
    private final AsyncConsumerActionExecutor connection;
    private final ConnectionParameters parameters;
    private final ProjectConnectionCloseListener listener;

    public DefaultProjectConnection(AsyncConsumerActionExecutor connection, ConnectionParameters parameters, ProjectConnectionCloseListener listener) {
        this.connection = connection;

import org.gradle.tooling.BuildAction
import org.gradle.tooling.IntermediateResultHandler
import org.gradle.tooling.internal.consumer.async.AsyncConsumerActionExecutor

class DefaultPhasedBuildActionExecuterBuilderTest extends Specification {
    def connection = Stub(AsyncConsumerActionExecutor)
    def parameters = Stub(ConnectionParameters)
    def builder = new DefaultBuildActionExecuter.Builder(connection, parameters)

import org.gradle.tooling.TestSpecs;
import org.gradle.tooling.events.test.TestOperationDescriptor;
import org.gradle.tooling.events.test.internal.DefaultDebugOptions;
import org.gradle.tooling.internal.consumer.async.AsyncConsumerActionExecutor;
import org.gradle.tooling.internal.consumer.connection.ConsumerAction;
import org.gradle.tooling.internal.consumer.connection.ConsumerConnection;