checkNotNull(service);
    checkNotNull(nameSupplier);
    return new WrappingExecutorService(service) {
      @Override
      protected <T extends @Nullable Object> Callable<T> wrapTask(Callable<T> callable) {
        return Callables.threadRenaming(callable, nameSupplier);
      }

      @Override
      protected Runnable wrapTask(Runnable command) {
        return Callables.threadRenaming(command, nameSupplier);

    checkNotNull(service);
    checkNotNull(nameSupplier);
    return new WrappingExecutorService(service) {
      @Override
      protected <T extends @Nullable Object> Callable<T> wrapTask(Callable<T> callable) {
        return Callables.threadRenaming(callable, nameSupplier);
      }

      @Override
      protected Runnable wrapTask(Runnable command) {
        return Callables.threadRenaming(command, nameSupplier);

import org.gradle.internal.reflect.JavaPropertyReflectionUtil;

import javax.annotation.Nullable;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.util.Collection;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.Callable;

import static org.gradle.internal.UncheckedException.uncheckedCall;

        is KtFunctionLiteral -> (parent as? KtLambdaExpression)?.unwrap()
        else -> this
    } ?: this
}

internal fun KaTypeNullability.toConeNullability() = when (this) {
    KaTypeNullability.NULLABLE -> ConeNullability.NULLABLE
    KaTypeNullability.NON_NULLABLE -> ConeNullability.NOT_NULL
    KaTypeNullability.UNKNOWN -> ConeNullability.UNKNOWN
}

/**
 * @receiver A symbol that needs to be imported

  }

  public void testSubmit_callable_returnsValue() throws Exception {
    Callable<Integer> callable =
        new Callable<Integer>() {
          @Override
          public Integer call() {
            return 42;
          }
        };
    ListenableFuture<Integer> future = submit(callable, directExecutor());
    assertThat(future.isDone()).isTrue();

  }

  public void testSubmit_callable_returnsValue() throws Exception {
    Callable<Integer> callable =
        new Callable<Integer>() {
          @Override
          public Integer call() {
            return 42;
          }
        };
    ListenableFuture<Integer> future = submit(callable, directExecutor());
    assertThat(future.isDone()).isTrue();

import javax.annotation.Nonnull;
import javax.annotation.Nullable;
import javax.inject.Inject;
import java.io.File;
import java.net.URI;
import java.util.ArrayList;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.TreeMap;
import java.util.TreeSet;
import java.util.concurrent.Callable;

import static com.google.common.base.Strings.isNullOrEmpty;

Accessors for org.gradle.api.internal.file.copy.DelegatingCopySpecInternal.dirMode don't use symmetrical @Nullable
Accessors for org.gradle.api.internal.file.copy.DelegatingCopySpecInternal.fileMode don't use symmetrical @Nullable
Accessors for org.gradle.api.internal.tasks.DefaultSourceSetOutput.resourcesDir don't use symmetrical @Nullable
Accessors for org.gradle.api.internal.tasks.TaskStateInternal.outcome don't use symmetrical @Nullable

import javax.annotation.Nullable;
import javax.inject.Inject;
import java.io.BufferedWriter;
import java.io.File;
import java.io.StringWriter;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collection;
import java.util.LinkedHashSet;
import java.util.List;
import java.util.Set;
import java.util.concurrent.Callable;

/**
 * The TestNG specific test options.
 */

Accessors for org.gradle.StartParameter.gradleUserHomeDir don't use symmetrical @Nullable
Accessors for org.gradle.StartParameter.taskNames don't use symmetrical @Nullable
Accessors for org.gradle.api.tasks.AbstractCopyTask.dirMode don't use symmetrical @Nullable
Accessors for org.gradle.api.tasks.AbstractCopyTask.fileMode don't use symmetrical @Nullable