import java.net.URI;
import java.util.Collections;
import java.util.List;
import java.util.Map;
import java.util.concurrent.CancellationException;
import java.util.concurrent.atomic.AtomicReference;

public class DistributionInstaller {
    private static final String APP_NAME = "Gradle Tooling API";
    private static final InternalBuildProgressListener NO_OP = new NoOpListener();
    private final ProgressLoggerFactory progressLoggerFactory;

            if (installedDistribution == null) {
                final DistributionInstaller installer = new DistributionInstaller(progressLoggerFactory, progressListener, clock);
                File installDir;
                try {
                    cancellationToken.addCallback(new Runnable() {

        1 * buildProgressListener.subscribedOperations >> [InternalBuildProgressListener.FILE_DOWNLOAD]
        1 * cancellationToken.addCallback(_)

        then:
        1 * progressLoggerFactory.newOperation(DistributionInstaller.class) >>> loggerOne
        1 * buildProgressListener.onEvent({it instanceof StartEvent})
        1 * loggerOne.setDescription("Download ${zipFile.toURI()}")
        1 * loggerOne.started()

        then:

Class <org.gradle.tooling.internal.consumer.DistributionInstaller$AsyncDownload$1> is not annotated (directly or via its package) with @org.gradle.api.NonNullApi in (DistributionInstaller.java:0)
Class <org.gradle.tooling.internal.consumer.DistributionInstaller$AsyncDownload> is not annotated (directly or via its package) with @org.gradle.api.NonNullApi in (DistributionInstaller.java:0)