parent
904a5995cd
commit
3699f00042
|
@ -50,11 +50,6 @@ public class PathChildren {
|
||||||
@Override
|
@Override
|
||||||
public void call(final Subscriber<? super PathChildrenCacheEvent> subscriber) {
|
public void call(final Subscriber<? super PathChildrenCacheEvent> subscriber) {
|
||||||
cache = new PathChildrenCache(curatorFramework, znodePath, true);
|
cache = new PathChildrenCache(curatorFramework, znodePath, true);
|
||||||
try {
|
|
||||||
cache.start(PathChildrenCache.StartMode.POST_INITIALIZED_EVENT);
|
|
||||||
} catch (Exception ex) {
|
|
||||||
subscriber.onError(ex);
|
|
||||||
}
|
|
||||||
|
|
||||||
cache.getListenable().addListener(new PathChildrenCacheListener() {
|
cache.getListenable().addListener(new PathChildrenCacheListener() {
|
||||||
@Override
|
@Override
|
||||||
|
@ -62,6 +57,12 @@ public class PathChildren {
|
||||||
subscriber.onNext(event);
|
subscriber.onNext(event);
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
|
try {
|
||||||
|
cache.start(PathChildrenCache.StartMode.POST_INITIALIZED_EVENT);
|
||||||
|
} catch (Exception ex) {
|
||||||
|
subscriber.onError(ex);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}).doOnUnsubscribe(new Action0() {
|
}).doOnUnsubscribe(new Action0() {
|
||||||
@Override
|
@Override
|
||||||
|
|
Loading…
Reference in New Issue