@Test
	public void testCacheIsOK() throws NacosException, InterruptedException {
		when(serviceDiscovery.getInstances("a"))
				.thenReturn(singletonList(serviceInstance));
		Flux<ServiceInstance> instances = this.client.getInstances("a");

		instances = instances.doOnComplete(() -> {
			if (!ServiceCache.getInstances("a").equals(singletonList(serviceInstance))) {
				throw new RuntimeException();
			}
		});

		StepVerifier.create(instances)
						.expectNext(serviceInstance)
						.expectComplete().verify();
	}
@author <a href="mailto:echooy.mxq@gmail.com">echooymxq</a>
@author freeman
spring-cloud-alibaba-starters/spring-cloud-starter-alibaba-nacos-discovery/src/test/java/com/alibaba/cloud/nacos/discovery/reactive/NacosReactiveDiscoveryClientTests.java