*/
public class DefaultAsyncConsumerActionExecutor implements AsyncConsumerActionExecutor {
    private final ConsumerActionExecutor actionExecutor;
    private final ManagedExecutor executor;
    private final ServiceLifecycle lifecycle;

    public DefaultAsyncConsumerActionExecutor(ConsumerActionExecutor actionExecutor, ExecutorFactory executorFactory) {

import org.gradle.tooling.ProjectConnection;
import org.gradle.tooling.internal.consumer.async.AsyncConsumerActionExecutor;
import org.gradle.tooling.internal.consumer.async.DefaultAsyncConsumerActionExecutor;
import org.gradle.tooling.internal.consumer.connection.CancellableConsumerActionExecutor;
import org.gradle.tooling.internal.consumer.connection.ConsumerActionExecutor;

    def actionExecuter = Mock(ConsumerActionExecutor) {
        getDisplayName() >> "[executer]"
    }
    def action = Mock(ConsumerAction)
    def handler = Mock(ResultHandlerVersion1)
    def connection = new DefaultAsyncConsumerActionExecutor(actionExecuter, executorFactory)

    def cleanup() {
        connection.stop()
    }

    def "runs action asynchronously"() {
        when:
        async {