import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class SingleFirePendingChangesListener implements PendingChangesListener {
    private static final Logger LOGGER = LoggerFactory.getLogger(SingleFirePendingChangesListener.class);

    private final PendingChangesListener delegate;
    private boolean seenChanges;

    public SingleFirePendingChangesListener(PendingChangesListener delegate) {
        this.delegate = delegate;
    }

    def "propagates changes only once"() {
        def singleFirePendingChangesListener = new SingleFirePendingChangesListener(delegate)

        when:
        singleFirePendingChangesListener.onPendingChanges()
        then:
        1 * delegate.onPendingChanges()

        when:
        singleFirePendingChangesListener.onPendingChanges()
        then:
        0 * delegate.onPendingChanges()
    }

            );
            SingleFirePendingChangesListener singleFirePendingChangesListener = new SingleFirePendingChangesListener(pendingChangesListener);
            FileEventCollector fileEventCollector = new FileEventCollector(buildInputs, () -> {
                continuousBuildTriggerHandler.notifyFileChangeArrived();
                singleFirePendingChangesListener.onPendingChanges();
            });
            try {

import org.gradle.integtests.fixtures.AbstractContinuousIntegrationTest
import org.gradle.test.fixtures.server.http.BlockingHttpServer
import org.gradle.tooling.internal.provider.continuous.SingleFirePendingChangesListener
import org.junit.Rule

class ContinuousBuildGateIntegrationTest extends AbstractContinuousIntegrationTest {
    @Rule BlockingHttpServer server = new BlockingHttpServer()

    def setup() {