Make polling frequency in PollingWatchService configurable about jimfs HOT 9 CLOSED

XYService underTest = new XYService() {
        @Override
        protected WatchService createWatchservice() throws IOException {
            WatchService watchservice = super.createWatchservice();
            //very ugly hack to make com.google.common.jimfs.PollingWatchService usable in a timely fashion
            //there is no straight forward way to configure the polling time (It's statically set to 5 SECONDS)
            ReflectionTestUtils.setField(watchservice, "pollingTime", 5);
            ReflectionTestUtils.setField(watchservice, "timeUnit", TimeUnit.MILLISECONDS);
            return watchservice;
        }
    };

package com.google.common.jimfs;

import java.io.IOException;
import java.nio.file.FileStore;
import java.nio.file.FileSystem;
import java.nio.file.Path;
import java.nio.file.PathMatcher;
import java.nio.file.WatchService;
import java.nio.file.attribute.UserPrincipalLookupService;
import java.nio.file.spi.FileSystemProvider;
import java.util.Set;
import java.util.concurrent.TimeUnit;

import org.assertj.core.util.Objects;

public class PollOnWatchFileSystemDecorator extends FileSystem
{

    private final JimfsFileSystem delegate;
    private final long pollingTime;
    private final TimeUnit timeUnit;

    public PollOnWatchFileSystemDecorator(FileSystem delegate, long pollingTime, TimeUnit timeUnit)
    {
        if (!(delegate instanceof JimfsFileSystem))
        {
            throw new RuntimeException(
                "Decorator only works with instances of the JimfsFileSystem");
        }

        this.delegate = Objects.castIfBelongsToType(delegate, JimfsFileSystem.class);
        this.pollingTime = pollingTime;
        this.timeUnit = timeUnit;
    }

    @Override
    public FileSystemProvider provider()
    {
        return delegate.provider();
    }

    @Override
    public void close() throws IOException
    {
        delegate.close();
    }

    @Override
    public boolean isOpen()
    {
        return delegate.isOpen();
    }

    @Override
    public boolean isReadOnly()
    {
        return delegate.isReadOnly();
    }

    @Override
    public String getSeparator()
    {
        return delegate.getSeparator();
    }

    @Override
    public Iterable<Path> getRootDirectories()
    {
        return delegate.getRootDirectories();
    }

    @Override
    public Iterable<FileStore> getFileStores()
    {
        return delegate.getFileStores();
    }

    @Override
    public Set<String> supportedFileAttributeViews()
    {
        return delegate.supportedFileAttributeViews();
    }

    @Override
    public Path getPath(String first, String... more)
    {
        return delegate.getPath(first, more);
    }

    @Override
    public PathMatcher getPathMatcher(String syntaxAndPattern)
    {
        return delegate.getPathMatcher(syntaxAndPattern);
    }

    @Override
    public UserPrincipalLookupService getUserPrincipalLookupService()
    {
        return delegate.getUserPrincipalLookupService();
    }

    @Override
    public WatchService newWatchService() throws IOException
    {
        return new PollingWatchService(delegate.getDefaultView(), delegate.getPathService(),
            delegate.getFileStore().state(), pollingTime, timeUnit);
    }

}

FileSystem unixFs = Jimfs.newFileSystem(com.google.common.jimfs.Configuration.unix());
FileSystem fileSystem = new PollOnWatchFileSystemDecorator(unixFs, 1, TimeUnit.SECONDS);