diff --git a/independent-projects/resteasy-reactive/client/runtime/src/main/java/org/jboss/resteasy/reactive/client/handlers/ClientSendRequestHandler.java b/independent-projects/resteasy-reactive/client/runtime/src/main/java/org/jboss/resteasy/reactive/client/handlers/ClientSendRequestHandler.java index 25b68110c220eb..b66bb0e00aae02 100644 --- a/independent-projects/resteasy-reactive/client/runtime/src/main/java/org/jboss/resteasy/reactive/client/handlers/ClientSendRequestHandler.java +++ b/independent-projects/resteasy-reactive/client/runtime/src/main/java/org/jboss/resteasy/reactive/client/handlers/ClientSendRequestHandler.java @@ -2,6 +2,7 @@ import io.netty.handler.codec.http.LastHttpContent; import io.netty.handler.codec.http.multipart.InterfaceHttpData; +import io.smallrye.mutiny.Multi; import io.smallrye.mutiny.Uni; import io.smallrye.stork.Stork; import io.smallrye.stork.api.ServiceInstance; @@ -408,7 +409,7 @@ public Uni createRequest(RestClientRequestContext state) { try { serviceInstance = Stork.getInstance() .getService(serviceName) - .selectInstanceAndRecordStart(true); + .selectInstanceAndRecordStart(!Multi.class.equals(state.getResponseType().getRawType())); } catch (Throwable e) { log.error("Error selecting service instance for serviceName: " + serviceName, e); return Uni.createFrom().failure(e);