[RESTEASY-2627] Chain thenCompose properly

asoldano · asoldano · commit c2f252118f65 · 2020-09-18T17:35:02.000+02:00
diff --git a/providers/multipart/src/main/java/org/jboss/resteasy/plugins/providers/multipart/HeaderFlushedAsyncOutputStream.java b/providers/multipart/src/main/java/org/jboss/resteasy/plugins/providers/multipart/HeaderFlushedAsyncOutputStream.java
@@ -46,7 +46,7 @@ protected CompletionStage<Void> flushHeaders() {
             } else {
                value = obj.toString();
             }
-            ret = stream.asyncWrite(key.getBytes(StandardCharsets.US_ASCII))
+            ret = ret.thenCompose(v -> stream.asyncWrite(key.getBytes(StandardCharsets.US_ASCII)))
                     .thenCompose(v -> stream.asyncWrite(AbstractMultipartWriter.COLON_SPACE_BYTES))
                     .thenCompose(v -> stream.asyncWrite(value.getBytes(StandardCharsets.US_ASCII)))
                     .thenCompose(v -> stream.asyncWrite(AbstractMultipartWriter.LINE_SEPARATOR_BYTES));

Original file line number	Diff line number	Diff line change
`@@ -46,7 +46,7 @@ protected CompletionStage<Void> flushHeaders() {`
`46`	`46`	`} else {`
`47`	`47`	`value = obj.toString();`
`48`	`48`	`}`
`49`		`- ret = stream.asyncWrite(key.getBytes(StandardCharsets.US_ASCII))`
	`49`	`+ ret = ret.thenCompose(v -> stream.asyncWrite(key.getBytes(StandardCharsets.US_ASCII)))`
`50`	`50`	`.thenCompose(v -> stream.asyncWrite(AbstractMultipartWriter.COLON_SPACE_BYTES))`
`51`	`51`	`.thenCompose(v -> stream.asyncWrite(value.getBytes(StandardCharsets.US_ASCII)))`
`52`	`52`	`.thenCompose(v -> stream.asyncWrite(AbstractMultipartWriter.LINE_SEPARATOR_BYTES));`