@Test public void testNoChanges() throws InterruptedException, IOException { long pollCycles = poller.getStats().getPollCycles(); while (poller.getStats().getPollCycles() == pollCycles) { Thread.sleep(25); } Assert.assertEquals(poller.getUpdatedFilesSinceLastTime().size(), 0); }
public Stats getStats() { return new Stats(stats); }
PollingMultiFileWatcher implements MultiFileWatcher { public Stats getStats() { return new Stats(stats); } }
PollingMultiFileWatcher implements MultiFileWatcher { public Stats getStats() { return new Stats(stats); } PollingMultiFileWatcher(Duration initialDelay, Duration interval); }
PollingMultiFileWatcher implements MultiFileWatcher { public Stats getStats() { return new Stats(stats); } PollingMultiFileWatcher(Duration initialDelay, Duration interval); @Override void start(Set<File> files, Consumer<Set<File>> callback); @Override boolean isStarted(); @Override void shutdown(); Stats getStats(); }
PollingMultiFileWatcher implements MultiFileWatcher { public Stats getStats() { return new Stats(stats); } PollingMultiFileWatcher(Duration initialDelay, Duration interval); @Override void start(Set<File> files, Consumer<Set<File>> callback); @Override boolean isStarted(); @Override void shutdown(); Stats getStats();  }