import org.gradle.tooling.CancellationToken;
import org.gradle.tooling.CancellationTokenSource;

public final class DefaultCancellationTokenSource implements CancellationTokenSource {
    private final CancellationTokenImpl tokenImpl;

    public DefaultCancellationTokenSource() {
        tokenImpl = new CancellationTokenImpl(new DefaultBuildCancellationToken());
    }

    @Override
    public void cancel() {

import org.gradle.internal.UncheckedException;
import org.gradle.internal.logging.progress.ProgressLoggerFactory;
import org.gradle.tooling.internal.consumer.ConnectionParameters;
import org.gradle.tooling.internal.consumer.DefaultCancellationTokenSource;
import org.gradle.tooling.internal.consumer.Distribution;
import org.gradle.tooling.internal.consumer.LoggingProvider;
import org.gradle.tooling.internal.consumer.loader.ToolingImplementationLoader;

 */

package org.gradle.tooling.internal.consumer

import spock.lang.Specification

class DefaultCancellationTokenSourceTest extends Specification {
    def source = new DefaultCancellationTokenSource()

    def 'token operation idempotent'() {
        when:
        def token1 = source.token()
        def token2 = source.token()

        then:
        token1 == token2
    }

        return singletonRegistry.getFactory(DefaultGradleConnector.class).create();
    }

    public static CancellationTokenSource createCancellationTokenSource() {
        return new DefaultCancellationTokenSource();
    }

    public static void close() {
        singletonRegistry.close();
    }

    /**
     * Resets the state of connector services. Meant to be used only for testing!
     */

import org.gradle.tooling.BuildLauncher
import org.gradle.tooling.GradleConnectionException
import org.gradle.tooling.events.OperationType
import org.gradle.tooling.internal.consumer.DefaultCancellationTokenSource
import org.gradle.util.GradleVersion
import org.junit.Rule
import spock.lang.Issue

import static org.gradle.test.matchers.UserAgentMatcher.matchesNameAndVersion

@LeaksFileHandles

        }
        final ConsumerOperationParameters.Builder operationParamsBuilder = ConsumerOperationParameters.builder();
        operationParamsBuilder.setCancellationToken(new DefaultCancellationTokenSource().token());
        operationParamsBuilder.setParameters(parameters);
        operationParamsBuilder.setEntryPoint("Notify daemons about changed paths API");
        connection.run(

        connectionParameters = parameters;
        operationParamsBuilder = ConsumerOperationParameters.builder();
        operationParamsBuilder.setCancellationToken(new DefaultCancellationTokenSource().token());
    }

    protected abstract T getThis();

    protected final ConsumerOperationParameters getConsumerOperationParameters() {

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