Java 类org.gradle.api.internal.tasks.testing.results.AttachParentTestResultProcessor 实例源码

@Override
public void startProcessing(TestResultProcessor resultProcessor) {
    // Build a result processor chain
    ClassLoader applicationClassLoader = Thread.currentThread().getContextClassLoader();
    TestResultProcessor resultProcessorChain = new AttachParentTestResultProcessor(resultProcessor);
    TestClassExecutionEventGenerator eventGenerator = new TestClassExecutionEventGenerator(resultProcessorChain, idGenerator, timeProvider);

    // Wrap the result processor chain up in a blocking actor, to make the whole thing thread-safe
    resultProcessorActor = actorFactory.createBlockingActor(eventGenerator);
    TestResultProcessor threadSafeResultProcessor = resultProcessorActor.getProxy(TestResultProcessor.class);
    TestClassExecutionListener threadSafeTestClassListener = resultProcessorActor.getProxy(TestClassExecutionListener.class);

    // Build the JUnit adaptor stuff
    JUnitTestEventAdapter junitEventAdapter = new JUnitTestEventAdapter(threadSafeResultProcessor, timeProvider, idGenerator);
    executer = new JUnitTestClassExecuter(applicationClassLoader, spec, junitEventAdapter, threadSafeTestClassListener);
}

@Override
public void startProcessing(TestResultProcessor testResultProcessor) {
    try {
        resultProcessor = new AttachParentTestResultProcessor(new CaptureTestOutputTestResultProcessor(testResultProcessor, new JULRedirector()));
        resultProcessor.started(suiteDescriptor, new TestStartEvent(timeProvider.getCurrentTime()));
        processor.startProcessing(resultProcessor);
    } catch (Throwable t) {
        resultProcessor.failure(suiteDescriptor.getId(), new TestSuiteExecutionException(String.format(
                "Could not start %s.", suiteDescriptor), t));
    }
}

public TestMainAction(Runnable detector, TestClassProcessor processor, TestResultProcessor resultProcessor, TimeProvider timeProvider, Object testTaskOperationId, Object rootTestSuiteId, String displayName) {
    this.detector = detector;
    this.processor = processor;
    this.resultProcessor = new AttachParentTestResultProcessor(resultProcessor);
    this.timeProvider = timeProvider;
    this.testTaskOperationId = testTaskOperationId;
    this.rootTestSuiteId = rootTestSuiteId;
    this.displayName = displayName;
}

public EclipseTestListener(TestResultProcessor testResultProcessor, String suite, Object waitMonitor, Object testTaskOperationId, Object rootTestSuiteId) {
    this.resultProcessor = new AttachParentTestResultProcessor(testResultProcessor);
    this.waitMonitor = waitMonitor;
    this.suiteName = suite;
    this.testTaskOperationId = testTaskOperationId;
    this.rootTestSuiteId = rootTestSuiteId;
}

public void startProcessing(TestResultProcessor resultProcessor) {
    // Build a result processor chain
    ClassLoader applicationClassLoader = Thread.currentThread().getContextClassLoader();
    TestResultProcessor resultProcessorChain = new AttachParentTestResultProcessor(new CaptureTestOutputTestResultProcessor(resultProcessor, outputRedirector));
    TestClassExecutionEventGenerator eventGenerator = new TestClassExecutionEventGenerator(resultProcessorChain, idGenerator, timeProvider);

    // Wrap the result processor chain up in a blocking actor, to make the whole thing thread-safe
    resultProcessorActor = actorFactory.createBlockingActor(eventGenerator);
    TestResultProcessor threadSafeResultProcessor = resultProcessorActor.getProxy(TestResultProcessor.class);
    TestClassExecutionListener threadSafeTestClassListener = resultProcessorActor.getProxy(TestClassExecutionListener.class);

    // Build the JUnit adaptor stuff
    JUnitTestEventAdapter junitEventAdapter = new JUnitTestEventAdapter(threadSafeResultProcessor, timeProvider, idGenerator);
    executer = new JUnitTestClassExecuter(applicationClassLoader, spec, junitEventAdapter, threadSafeTestClassListener);
}

public void startProcessing(TestResultProcessor testResultProcessor) {
    try {
        resultProcessor = new AttachParentTestResultProcessor(testResultProcessor);
        resultProcessor.started(suiteDescriptor, new TestStartEvent(timeProvider.getCurrentTime()));
        processor.startProcessing(resultProcessor);
    } catch (Throwable t) {
        resultProcessor.failure(suiteDescriptor.getId(), new TestSuiteExecutionException(String.format(
                "Could not start %s.", suiteDescriptor), t));
    }
}

public void startProcessing(TestResultProcessor resultProcessor) {
    // Build a result processor chain
    ClassLoader applicationClassLoader = Thread.currentThread().getContextClassLoader();
    TestResultProcessor resultProcessorChain = new AttachParentTestResultProcessor(new CaptureTestOutputTestResultProcessor(resultProcessor, outputRedirector));
    TestClassExecutionEventGenerator eventGenerator = new TestClassExecutionEventGenerator(resultProcessorChain, idGenerator, timeProvider);

    // Wrap the result processor chain up in a blocking actor, to make the whole thing thread-safe
    resultProcessorActor = actorFactory.createBlockingActor(eventGenerator);
    TestResultProcessor threadSafeResultProcessor = resultProcessorActor.getProxy(TestResultProcessor.class);
    TestClassExecutionListener threadSafeTestClassListener = resultProcessorActor.getProxy(TestClassExecutionListener.class);

    // Build the JUnit adaptor stuff
    JUnitTestEventAdapter junitEventAdapter = new JUnitTestEventAdapter(threadSafeResultProcessor, timeProvider, idGenerator);
    executer = new JUnitTestClassExecuter(applicationClassLoader, spec, junitEventAdapter, threadSafeTestClassListener);
}

public void startProcessing(TestResultProcessor testResultProcessor) {
    try {
        resultProcessor = new AttachParentTestResultProcessor(testResultProcessor);
        resultProcessor.started(suiteDescriptor, new TestStartEvent(timeProvider.getCurrentTime()));
        processor.startProcessing(resultProcessor);
    } catch (Throwable t) {
        resultProcessor.failure(suiteDescriptor.getId(), new TestSuiteExecutionException(String.format(
                "Could not start %s.", suiteDescriptor), t));
    }
}

public TestMainAction(Runnable detector, TestClassProcessor processor, TestResultProcessor resultProcessor, TimeProvider timeProvider) {
    this.detector = detector;
    this.processor = processor;
    this.resultProcessor = new AttachParentTestResultProcessor(resultProcessor);
    this.timeProvider = timeProvider;
}

public TestMainAction(Runnable detector, TestClassProcessor processor, TestResultProcessor resultProcessor, TimeProvider timeProvider) {
    this.detector = detector;
    this.processor = processor;
    this.resultProcessor = new AttachParentTestResultProcessor(resultProcessor);
    this.timeProvider = timeProvider;
}