MavenExecutionResult result,
            MavenChainedWorkspaceReader chainedWorkspaceReader) {
        try {
            afterSessionStart(session);
        } catch (MavenExecutionException e) {
            return addExceptionToResult(result, e);
        }

        try {
            chainedWorkspaceReader.addReader(lookup.lookup(WorkspaceReader.class, ReactorReader.HINT));

            }
        });

        try {
            serializedToolchains = interpolator.interpolate(serializedToolchains);
        } catch (InterpolationException e) {
            problems.add(Problem.Severity.ERROR, "Failed to interpolate toolchains: " + e.getMessage(), -1, -1, e);
            return toolchains;
        }

        PersistedToolchains result;
        try {

    }
}

private InetAddress discoverWitnessService() throws IOException {
    // Try the same server first
    InetAddress serverAddress = transport.getRemoteAddress();
    
    if (isWitnessServiceAvailable(serverAddress)) {
        return serverAddress;
    }
    
    // Query for cluster witness service via DNS
    try {
        String clusterName = getClusterName(serverAddress);
        if (clusterName != null) {

    @Override
    public boolean isAvailable() {
        try {
            return storage.get(bucket) != null;
        } catch (final Exception e) {
            return false;
        }
    }

    @Override
    public void close() {
        // GCS Storage client doesn't require explicit close
        // but we can try to close it if needed
        try {
            storage.close();

        try (BufferedReader br = new BufferedReader(readerSupplier.open(), BUFFER_SIZE)) {
            br.mark(BUFFER_SIZE);
            XMLStreamReader xsr = XMLInputFactory.newFactory().createXMLStreamReader(br);
            xsr.nextTag();
            String nsUri = xsr.getNamespaceURI();
            try (BufferedReader br2 = reset(readerSupplier, br)) {

  override fun afterHandshake(sslSocket: SSLSocket) {
    try {
      removeMethod.invoke(null, sslSocket)
    } catch (e: IllegalAccessException) {
      throw AssertionError("failed to remove ALPN", e)
    } catch (e: InvocationTargetException) {
      throw AssertionError("failed to remove ALPN", e)
    }
  }

  override fun getSelectedProtocol(sslSocket: SSLSocket): String? {
    try {

     */
    public static void load(final Properties props, final InputStream in) {
        assertArgumentNotNull("props", props);
        assertArgumentNotNull("in", in);

        try {
            props.load(in);
        } catch (final IOException e) {
            throw new IORuntimeException(e);
        }
    }

    /**
     * Wraps exception handling for {@link Properties#load(Reader)}.

      postponedRoutes.clear()
    }

    return Selection(routes)
  }

  /** Prepares the proxy servers to try. */
  private fun resetNextProxy(
    url: HttpUrl,
    proxy: Proxy?,
  ) {
    fun selectProxies(): List<Proxy> {
      // If the user specifies a proxy, try that and only that.
      if (proxy != null) return listOf(proxy)

    }

    public void testParse() {
        RobotsTxt robotsTxt;
        final InputStream in = RobotsTxtHelperTest.class.getResourceAsStream("robots.txt");
        try {
            robotsTxt = robotsTxtHelper.parse(in);
        } finally {
            CloseableUtil.closeQuietly(in);
        }

        }
        final ResponseData responseData = new ResponseData();
        try {
            responseData.setMethod(Constants.GET_METHOD);
            final String filePath = preprocessUri(uri);
            responseData.setUrl(filePath);

            File file = null;
            try {
                file = new File(new URI(filePath));
            } catch (final URISyntaxException e) {