LocalApplicationRunner implements ApplicationRunner { @Override public void waitForFinish() { this.waitForFinish(Duration.ofSeconds(0)); } LocalApplicationRunner(SamzaApplication app, Config config);  LocalApplicationRunner(SamzaApplication app, Config config, MetadataStoreFactory metadataStoreFactory); @VisibleForTesting  LocalApplicationRunner(SamzaApplication app, Config config, CoordinationUtils coordinationUtils); private  LocalApplicationRunner(LocalApplicationRunnerContext context); Optional<String> getRunId(); @Override void run(ExternalContext externalContext); @Override void kill(); @Override ApplicationStatus status(); @Override void waitForFinish(); @Override boolean waitForFinish(Duration timeout);  }
@Test public void testWaitForFinishTimesout() { long timeoutInMs = 100; boolean finished = runner.waitForFinish(Duration.ofMillis(timeoutInMs)); assertFalse("Application finished before the timeout.", finished); }