@Test public void testInitFromEtcd_CallsListener() throws Exception { client.put(FLAGZ_PATH + "etcd_test_int", "333").send().get(); etcdUpdater.init(); assertThat(flagInt.get(), is(333)); verify(intListener).accept(eq(333)); }
public void init() { init(Preconditions.checkNotNull(Strings.emptyToNull(directoryFlag.get()))); }
EtcdFlagFieldUpdater { public void init() { init(Preconditions.checkNotNull(Strings.emptyToNull(directoryFlag.get()))); } }
EtcdFlagFieldUpdater { public void init() { init(Preconditions.checkNotNull(Strings.emptyToNull(directoryFlag.get()))); } EtcdFlagFieldUpdater(FlagFieldRegistry registry);   EtcdFlagFieldUpdater(FlagFieldRegistry registry, List<String> uris, RetryPolicy retryPolicy,
                       ExecutorService executorService); }
EtcdFlagFieldUpdater { public void init() { init(Preconditions.checkNotNull(Strings.emptyToNull(directoryFlag.get()))); } EtcdFlagFieldUpdater(FlagFieldRegistry registry);   EtcdFlagFieldUpdater(FlagFieldRegistry registry, List<String> uris, RetryPolicy retryPolicy,
                       ExecutorService executorService); static boolean isEnabled(); void init(); void init(String flagzDirectory); void watchForUpdates(); void stop(); }
EtcdFlagFieldUpdater { public void init() { init(Preconditions.checkNotNull(Strings.emptyToNull(directoryFlag.get()))); } EtcdFlagFieldUpdater(FlagFieldRegistry registry);   EtcdFlagFieldUpdater(FlagFieldRegistry registry, List<String> uris, RetryPolicy retryPolicy,
                       ExecutorService executorService); static boolean isEnabled(); void init(); void init(String flagzDirectory); void watchForUpdates(); void stop();  }