handler.handleChange(OVERFLOW, Paths.get(watchedRoot)));
                                } else {
                                    LOGGER.info("Overflow detected (type: {}) for watched path '{}', invalidating", type, absolutePath);
                                    handler.handleChange(OVERFLOW, Paths.get(absolutePath));
                                }

            this.delegate = delegate;
        }

        @Override
        public void handleChange(FileWatcherRegistry.Type type, Path path) {
            if (locationsWrittenByCurrentBuild.shouldWatchLocation(path.toString())) {
                delegate.handleChange(type, path);
            }
        }

        @Override
        public void stopWatchingAfterError() {

        broadcaster.remove(listener);
    }

    @Override
    public void broadcastChange(FileWatcherRegistry.Type type, Path path) {
        broadcaster.getSource().handleChange(type, path);
    }

    @Override
    public void broadcastWatchingError() {
        broadcaster.getSource().stopWatchingAfterError();
    }

import java.util.List;
import java.util.Optional;

public interface FileWatcherRegistry extends Closeable {

    boolean isWatchingAnyLocations();

    interface ChangeHandler {
        void handleChange(Type type, Path path);

        void stopWatchingAfterError();
    }

    enum Type {
        CREATED,
        MODIFIED,
        REMOVED,
        INVALIDATED,
        OVERFLOW
    }

    /**

        this.buildInputs = buildInputs;
        this.onRelevantChangeAction = onRelevantChangeAction;
    }

    @Override
    public void handleChange(FileWatcherRegistry.Type type, Path path) {
        String absolutePath = path.toString();
        if (buildInputs.isInput(absolutePath)) {
            // got a change, store it
            onChangeToInputs(type, path);