@Override
	public Flux<ServiceInstance> getInstances(String serviceId) {
		return Flux.defer(() -> Flux.fromIterable(eurekaClient.getInstancesByVipAddress(serviceId, false)))
			.map(EurekaServiceInstance::new);
	}
A {@link ReactiveDiscoveryClient} implementation for Eureka.

@author Tim Ysewyn
spring-cloud-netflix-eureka-client/src/main/java/org/springframework/cloud/netflix/eureka/reactive/EurekaReactiveDiscoveryClient.java