@Override
    public Flux<String> getServices() {
        return Flux.defer(() -> Flux.fromIterable(getRegisterCenterService().getServices()))
                .onErrorResume(ex -> {
                    LOGGER.error("Can not acquire services list", ex);
                    return Flux.empty();
                }).subscribeOn(Schedulers.boundedElastic());
    }
@Test
    public void getServices() {
        final Flux<String> services = client.getServices();
        final List<String> block = services.collectList().block();
        Assert.assertNotNull(block);
        Assert.assertEquals(block.size(), SERVICES.size());
        for (int i = 0; i < block.size(); i++) {
            Assert.assertEquals(block.get(i), SERVICES.get(i));
        }
    }