Skip to content

Conversation

wind57
Copy link
Contributor

@wind57 wind57 commented Aug 26, 2025

No description provided.

Signed-off-by: wind57 <[email protected]>
@@ -57,32 +57,34 @@ public KubernetesClientServicesListSupplier(Environment environment,

@Override
public Flux<List<ServiceInstance>> get() {
List<ServiceInstance> result = new ArrayList<>();
Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

we had our code as :

public Flux<List<ServiceInstance>> get() { 

      List<ServiceInstance> result = ....
      return Flux.just(result); 

}

and it changes to :

public Flux<List<ServiceInstance>> get() { 

      return Flux.defer(() -> {
                 List<ServiceInstance> result = ....
                 return Flux.just(result); 
      })
}

That is the actual fix.

List<ServiceInstance> result = new ArrayList<>();
String serviceName = getServiceId();
LOG.debug(() -> "serviceID : " + serviceName);
return Flux.defer(() -> {
Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

same fix as above, nothing changes besides that

@@ -63,24 +56,4 @@ public static Endpoints endpoints(int port, String host, String namespace) {
.build();
}

@TestConfiguration
public static class LoadBalancerConfiguration {
Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

not removed, but moved to individual classes

wind57 added 2 commits August 29, 2025 19:11
Signed-off-by: wind57 <[email protected]>
Signed-off-by: wind57 <[email protected]>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants