6.times {
                start {
                    thread.blockUntil.allStarted
                    WorkQueue queue = workerExecutor."${isolationMode}" Actions.doNothing()
                    queue.submit(TestExecution.class, Actions.doNothing())
                }
            }
            instant.allStarted
        }

        then:
        6 * workerThreadRegistry.workerThread >> true
        6 * executionQueue.submit(_)

            def action = connection.action(new NullAction())
            action.standardOutput = outputStream
            action.run()
        }
    }

    // since 2.6
    def testExecution() {
        buildFile << """
apply plugin: 'java'
repositories {
    maven {
        url '${buildContext.localRepository.toURI()}'
    }
}
${mavenCentralRepository()}
dependencies {

 */
public interface InternalBuildProgressListener {

    /**
     * The constant for the test execution operations.
     */
    String TEST_EXECUTION = "TEST_EXECUTION";

    /**
     * The constant for the task execution operations.
     */
    String TASK_EXECUTION = "TASK_EXECUTION";

    /**
     * The constant for the build execution operations.
     */

import static org.gradle.tooling.internal.protocol.InternalBuildProgressListener.TASK_EXECUTION
import static org.gradle.tooling.internal.protocol.InternalBuildProgressListener.TEST_EXECUTION
import static org.gradle.tooling.internal.protocol.InternalBuildProgressListener.TEST_OUTPUT
import static org.gradle.tooling.internal.protocol.InternalBuildProgressListener.TRANSFORM_EXECUTION

        then:
        1 * buildProgressListener.subscribedOperations >> [InternalBuildProgressListener.TEST_EXECUTION]
        1 * cancellationToken.addCallback(_)

        then:
        1 * progressLoggerFactory.newOperation(DistributionInstaller.class) >>> loggerOne

        when:
        def listener = Mock(ProgressListener)
        adapter = createAdapter(listener)

        then:
        adapter.subscribedOperations == [InternalBuildProgressListener.TEST_EXECUTION]
    }

    def "only TestProgressEventX instances are processed if a test listener is added"() {
        given:
        def listener = Mock(ProgressListener)
        def adapter = createAdapter(listener)

        private static final Map<String, OperationType> OPERATION_TYPE_MAPPING = ImmutableMap.<String, OperationType>builderWithExpectedSize(OperationType.values().length)
            .put(InternalBuildProgressListener.TEST_EXECUTION, OperationType.TEST)
            .put(InternalBuildProgressListener.TASK_EXECUTION, OperationType.TASK)
            .put(InternalBuildProgressListener.WORK_ITEM_EXECUTION, OperationType.WORK_ITEM)

    public List<String> getSubscribedOperations() {
        List<String> operations = new ArrayList<>();

        if (!testProgressListeners.isEmpty()) {
            operations.add(InternalBuildProgressListener.TEST_EXECUTION);
        }
        if (!taskProgressListeners.isEmpty()) {
            operations.add(InternalBuildProgressListener.TASK_EXECUTION);
        }
        if (!buildOperationProgressListeners.isEmpty()) {