Future<?> scheduled = executorService.schedule(task, delay, timeUnit);
    /*
     * Even when the user interrupts the task, we pass `false` to `cancel` so that we don't
     * interrupt a second time after the interruption performed by TrustedListenableFutureTask.
     */
    task.addListener(() -> scheduled.cancel(false), directExecutor());
    return task;
  }

  }

  @Override
  public void tearDown() throws Exception {
    super.tearDown();
    /*
     * TODO(cpovirk): Run tests in another thread instead of messing with main thread's interrupted
     * status.
     */
    Thread.interrupted();
    LocalCache.logger.removeHandler(logHandler);
  }

  private Throwable popLoggedThrowable() {
    List<LogRecord> logRecords = logHandler.getStoredLogRecords();

				"application/vnd.immervision-ivu",
				"application/vnd.informedcontrol.rms+xml",
				"application/vnd.informix-visionary",
				"application/vnd.intercon.formnet",
				"application/vnd.intertrust.digibox",
				"application/vnd.intertrust.nncp",
				"application/vnd.intu.qbo",
				"application/vnd.intu.qfx",
				"application/vnd.iptc.g2.conceptitem+xml",
				"application/vnd.iptc.g2.knowledgeitem+xml",

	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;

    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

    val client2 =
      client
        .newBuilder()
        .addNetworkInterceptor(
          object : Interceptor {
            var executedCall = false

            override fun intercept(chain: Interceptor.Chain): Response {
              if (!executedCall) {
                // At this point, we have a healthy HTTP/2 connection. This call will trigger the