@Override
    void assertTestSkippedOrPassed(TestClassExecutionResult testClassResult, String testName) {
        testClassResult.assertTestSkipped(testName)
    }

            @Override
            public void execute(final BuildOperationQueue<JUnitXmlReportFileGenerator> queue) {
                testResultsProvider.visitClasses(new Action<TestClassResult>() {
                    @Override
                    public void execute(final TestClassResult result) {
                        final File reportFile = new File(testResultsDir, getReportFileName(result));

class JUnit4SmokeMultiVersionIntegrationTest extends AbstractJUnitSmokeMultiVersionIntegrationTest implements JUnit4MultiVersionTest {
    @Override
    void assertTestSkippedOrPassed(TestClassExecutionResult testClassResult, String testName) {
        testClassResult.assertTestPassed(testName)
    }

    }

    def "writes results - #numThreads parallel thread(s)"() {
        generator = generatorWithMaxThreads(numThreads)

        def fooTest = new TestClassResult(1, 'FooTest', 100)
            .add(new TestMethodResult(1, "foo"))

        def barTest = new TestClassResult(2, 'BarTest', 100)
            .add(new TestMethodResult(2, "bar"))
            .add(new TestMethodResult(3, "bar2"))

        final AllTestResults model = new AllTestResults();
        resultsProvider.visitClasses(new Action<TestClassResult>() {
            @Override
            public void execute(TestClassResult classResult) {
                model.addTestClass(classResult.getId(), classResult.getClassName(), classResult.getClassDisplayName());

    }

    def "merges for simple case - output per testcase"() {
        when:
        def testClass = provider.testClassResult("com.Flaky") {
            stdout "class-out"
            stderr "class-err"
            testcase("m1") {
                stderr "m1-err-1"
                stdout "m1-out-1"

                reader.writeTestOutput(classId, testId, destination, writer);
            }
        });
    }

    @Override
    public void visitClasses(final Action<? super TestClassResult> visitor) {
        resultSerializer.read(visitor);
    }

    /**
     * Visits the results of each test class, in no specific order. Each class is visited exactly once.
     */
    void visitClasses(Action<? super TestClassResult> visitor);

    boolean hasOutput(long classId, TestOutputEvent.Destination destination);

    boolean hasOutput(long classId, long testId, TestOutputEvent.Destination destination);

    boolean isHasResults();

import org.gradle.api.tasks.testing.TestResult
import spock.lang.Specification

class TestClassResultSpec extends Specification {

    def "provides test class result information"() {
        def result = new TestClassResult(1, 'class', 100)
        assert result.duration == 0

        when:
        result.add(new TestMethodResult(1, "foo").completed(new DefaultTestResult(TestResult.ResultType.SUCCESS, 100, 200, 1, 1, 0, [])))

            public void execute(DeleteSpec spec) {
                spec.delete(binaryResultsDir);
            }
        });
        binaryResultsDir.mkdirs();

        Map<String, TestClassResult> results = new HashMap<String, TestClassResult>();
        TestOutputStore testOutputStore = new TestOutputStore(binaryResultsDir);

        TestOutputStore.Writer outputWriter = testOutputStore.writer();