@Test public void testGetNodesAfterRemoveNode() throws Exception { createNode(FOO); assertTrue(waitUntilSize(_nodeDiscovery.getNodes(), 1)); deleteNode(FOO); assertTrue(waitUntilSize(_nodeDiscovery.getNodes(), 0)); }
public Map<String, T> getNodes() { return Maps.transformValues(Collections.unmodifiableMap(_nodes), input -> (input != null) ? input.orElse(null) : null); }
NodeDiscovery implements Closeable { public Map<String, T> getNodes() { return Maps.transformValues(Collections.unmodifiableMap(_nodes), input -> (input != null) ? input.orElse(null) : null); } }
NodeDiscovery implements Closeable { public Map<String, T> getNodes() { return Maps.transformValues(Collections.unmodifiableMap(_nodes), input -> (input != null) ? input.orElse(null) : null); } NodeDiscovery(CuratorFramework curator, String nodePath, NodeDataParser<T> parser); }
NodeDiscovery implements Closeable { public Map<String, T> getNodes() { return Maps.transformValues(Collections.unmodifiableMap(_nodes), input -> (input != null) ? input.orElse(null) : null); } NodeDiscovery(CuratorFramework curator, String nodePath, NodeDataParser<T> parser); void start(); Map<String, T> getNodes(); boolean contains(T node); void addListener(NodeListener<T> listener); void removeListener(NodeListener<T> listener); @Override synchronized void close(); }
NodeDiscovery implements Closeable { public Map<String, T> getNodes() { return Maps.transformValues(Collections.unmodifiableMap(_nodes), input -> (input != null) ? input.orElse(null) : null); } NodeDiscovery(CuratorFramework curator, String nodePath, NodeDataParser<T> parser); void start(); Map<String, T> getNodes(); boolean contains(T node); void addListener(NodeListener<T> listener); void removeListener(NodeListener<T> listener); @Override synchronized void close();  }