try {
                latch.await();
            } catch (InterruptedException e) {
                result.addErrorArtifactException(
                        new ArtifactResolutionException("Resolution interrupted", rootArtifact, e));
            }
        }

        // We want to send the root artifact back in the result but we need to do this after the other dependencies
        // have been resolved.

        }

        indexUpdater.setFinishCrawling(true);
        try {
            indexUpdater.join();
        } catch (final InterruptedException e) {
            logger.warn("Interrupted index update.", e);
        }

        crawlingInfoHelper.putToInfoMap(Constants.WEB_FS_INDEX_EXEC_TIME, Long.toString(indexUpdater.getExecuteTime()));

		// This is needed as the remote hosts are sometime
		// not available immediately.
		select {
		case <-globalOSSignalCh:
			return fmt.Errorf("The endpoint resolution got interrupted")
		default:
			for i, resolved := range resolvedList {
				if resolved {
					// Continue if host is already resolved.
					continue
				}

				if endpoints[i].Host == "" {

    client =
      OkHttpClient
        .Builder()
        .addNetworkInterceptor(
          Interceptor { chain ->
            when {
              extraNetworkInterceptor != null -> extraNetworkInterceptor!!.intercept(chain)
              else -> chain.proceed(chain.request())
            }
          },
        ).addNetworkInterceptor(networkInterceptor)
        .addInterceptor(applicationInterceptor)
        .sslSocketFactory(

            executor.awaitTermination(executorTerminationTimeout, TimeUnit.SECONDS);
        } catch (final InterruptedException e) {
            if (logger.isDebugEnabled()) {
                logger.debug("Executor shutdown interrupted", e);
            }
        } finally {
            executor.shutdownNow();
        }

        synchronized (indexUpdateCallback) {
            if (!deleteUrlList.isEmpty()) {

	public fun <init> ([Lokhttp3/CompressionInterceptor$DecompressionAlgorithm;)V
	public final fun getAlgorithms ()[Lokhttp3/CompressionInterceptor$DecompressionAlgorithm;
	public fun intercept (Lokhttp3/Interceptor$Chain;)Lokhttp3/Response;
}

public abstract interface class okhttp3/CompressionInterceptor$DecompressionAlgorithm {
	public abstract fun decompress (Lokio/BufferedSource;)Lokio/Source;

     *
     * @param consumer Consumer function to configure the bulk request builder
     * @return true if all bulk operations were successful, false otherwise
     * @throws InterruptedRuntimeException if the operation is interrupted
     * @throws SearchEngineClientException if the bulk update fails
     */
    public boolean bulkUpdate(final Consumer<BulkRequestBuilder> consumer) {

    interceptor.redactHeader("")
    interceptor.level = HttpLoggingInterceptor.Level.BASIC
    var level: HttpLoggingInterceptor.Level = interceptor.level
    interceptor.intercept(newInterceptorChain())
  }

  @Test
  fun httpLoggingInterceptorLevel() {
    val none: HttpLoggingInterceptor.Level = HttpLoggingInterceptor.Level.NONE

	public fun <init> ([Lokhttp3/CompressionInterceptor$DecompressionAlgorithm;)V
	public final fun getAlgorithms ()[Lokhttp3/CompressionInterceptor$DecompressionAlgorithm;
	public fun intercept (Lokhttp3/Interceptor$Chain;)Lokhttp3/Response;
}

public abstract interface class okhttp3/CompressionInterceptor$DecompressionAlgorithm {
	public abstract fun decompress (Lokio/BufferedSource;)Lokio/Source;

                        }
                        break;
                    } catch (final InterruptedException e) {
                        final InterruptedIOException ie = new InterruptedIOException("Interrupted while acquiring credits");
                        ie.initCause(e);
                        throw ie;
                    }
                } else {
                    // not enough credits available or too big, split