mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/impl/DefaultHttpServerProvider.java [74:94]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        return Observable.create(new OnSubscribe<ServerInfo>() {
            @Override
            public void call(final Subscriber<? super ServerInfo> subscriber) {
                // Single out the assignment to make type inference happy
                Set<ServerInfo> empty = Collections.emptySet();
                final AtomicReference<Set<ServerInfo>> activeServers = new AtomicReference<>(empty);

                Subscription subs = serverPoller.servers()
                        .subscribe(new Subscriber<Set<ServerInfo>>() {
                            @Override
                            public void onCompleted() {
                                subscriber.onCompleted();
                            }

                            @Override
                            public void onError(Throwable e) {
                                subscriber.onError(e);
                            }

                            @Override
                            public void onNext(Set<ServerInfo> servers) {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/impl/DefaultHttpServerProvider.java [118:138]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        return Observable.create(new OnSubscribe<ServerInfo>() {
            @Override
            public void call(final Subscriber<? super ServerInfo> subscriber) {
                // Single out the assignment to make type inference happy
                Set<ServerInfo> empty = Collections.emptySet();
                final AtomicReference<Set<ServerInfo>> activeServers = new AtomicReference<>(empty);

                Subscription subs = serverPoller.servers()
                        .subscribe(new Subscriber<Set<ServerInfo>>() {
                            @Override
                            public void onCompleted() {
                                subscriber.onCompleted();
                            }

                            @Override
                            public void onError(Throwable e) {
                                subscriber.onError(e);
                            }

                            @Override
                            public void onNext(Set<ServerInfo> servers) {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -