*     we've successfully connected or because no further attempts should be made.
   */
  @Throws(IOException::class)
  internal fun connectTunnel(): ConnectResult {
    val nextTunnelRequest =
      createTunnel()
        ?: return ConnectResult(plan = this) // Success.

    // The proxy decided to close the connection after an auth challenge. Retry with different
    // auth credentials.
    rawSocket?.closeQuietly()

        when:
        createRunner().withTestKitDir(null)

        then:
        def t = thrown(IllegalArgumentException)
        t.message == 'testKitDir argument cannot be null'
    }

    def "can set custom test kit directory"() {
        given:
        def testKitDir = testDirectoryProvider.createDir('some/dir')

        when:
        def runner = createRunner()
            .withProjectDir(workingDir)

        }

        @Override
        protected ExecutionResult doRun() {
            def runnerResult = createRunner().build()
            return OutputScrapingExecutionResult.from(runnerResult.output, "")
        }

        @Override
        protected ExecutionFailure doRunWithFailure() {
            def runnerResult = createRunner().buildAndFail()
            return OutputScrapingExecutionFailure.from(runnerResult.output, "")
        }

                }
            });
            schedulerTime = now;
        }, fessConfig.getSchedulerMonitorIntervalAsInteger(), true);
    }

    @Override
    public LaJobRunner createRunner() {
        return new LaJobRunner().useAccessContext(
                resource -> accessContextLogic.create(resource, OptionalThing::empty, OptionalThing::empty, () -> APP_TYPE));
    }

org.junit.runner.Request { private final java.util.concurrent.locks.Lock runnerLock; private volatile org.junit.runner.Runner runner; void MemoizingRequest(); public final org.junit.runner.Runner getRunner(); protected abstract org.junit.runner.Runner createRunner(); } org/junit/internal/requests/ClassRequest$1.class package org.junit.internal.requests; synchronized class ClassRequest$1 { } org/junit/internal/requests/ClassRequest$CustomAllDefaultPoss.class package org.junit.internal.requests; synchronized...