.Builder()
        .webSocketUpgrade(serverListener)
        .build(),
    )
    val e = RuntimeException()
    clientListener.setNextEventDelegate(
      object : WebSocketListener() {
        override fun onOpen(
          webSocket: WebSocket,
          response: Response,
        ): Unit = throw e
      },
    )
    newWebSocket()
    serverListener.assertOpen()

    @JvmField
    val NO_COOKIES: CookieJar = NoCookies()

    private class NoCookies : CookieJar {
      override fun saveFromResponse(
        url: HttpUrl,
        cookies: List<Cookie>,
      ) {
      }

      override fun loadForRequest(url: HttpUrl): List<Cookie> = emptyList()
    }
  }

          assertThat(dispatcherF.closed).isFalse() // Never started.
        }
      }
  }

  class ClosableDispatcher : Dispatcher() {
    var closed = false

    override fun dispatch(request: RecordedRequest) = MockResponse()

    override fun close() {
      closed = true
    }
  }

  @StartStop private val mockWebServer = MockWebServer()

  @Test
  fun simpleDispatch() {
    val requestsMade = mutableListOf<RecordedRequest>()
    val dispatcher: Dispatcher =
      object : Dispatcher() {
        override fun dispatch(request: RecordedRequest): MockResponse {
          requestsMade.add(request)
          return MockResponse()
        }
      }
    assertThat(requestsMade.size).isEqualTo(0)

    public DebugConfigurationListener(Logger logger) {
        this.logger = logger;
    }

    @Override
    public void notifyFieldChangeUsingSetter(String fieldName, Object value, Object target) {
        if (logger.isDebugEnabled()) {
            logger.debug("  (s) " + fieldName + " = " + toString(value));
        }
    }

    @Override
    public void notifyFieldChangeUsingReflection(String fieldName, Object value, Object target) {

    public static final String AGGR = "aggr";

    public static final String INSTALL = "install";

    public LifecycleTaskSegmentCalculatorStub() {
        super(null, null);
    }

    @Override
    public List<TaskSegment> calculateTaskSegments(MavenSession session, List<String> tasks)
            throws PluginNotFoundException, PluginResolutionException, PluginDescriptorParsingException,

     */
    private class TestIterator extends FileEntryAdapterIterator {
        TestIterator(ResourceFilter filter) {
            super(parent, delegate, filter);
        }

        @Override
        protected SmbResource adapt(FileEntry e) throws MalformedURLException {
            return resource;
        }
    }

    @BeforeEach
    void setUp() {

    }

    @Override
    public FileInputStream openStream() throws IOException {
      return new FileInputStream(file);
    }

    @Override
    public Optional<Long> sizeIfKnown() {
      if (file.isFile()) {
        return Optional.of(file.length());
      } else {
        return Optional.absent();
      }
    }

    @Override
    public long size() throws IOException {

     *
     * @return the number of documents processed
     */
    @Override
    public long getDocumentSize() {
        return documentSize.get();
    }

    /**
     * Returns the total execution time for all operations.
     *
     * @return the total execution time in milliseconds
     */
    @Override
    public long getExecuteTime() {
        return executeTime;
    }

    return result;
  }

  @SuppressWarnings("rawtypes") // class literals
  @Override
  protected List<Class<? extends AbstractTester>> getTesters() {
    List<Class<? extends AbstractTester>> testers = copyToList(super.getTesters());
    testers.addAll(ConcurrentMapTestSuiteBuilder.TESTERS);
    return testers;
  }

  @Override
  NavigableMapTestSuiteBuilder<K, V> subSuiteUsing(TestSortedMapGenerator<K, V> generator) {