Skip to content

Commit ed148fc

Browse files
committed
Remove ReadStream methods with callbacks and propagate in the stack
1 parent ab134e9 commit ed148fc

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/main/java/io/vertx/httpproxy/impl/ProxiedResponse.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -229,7 +229,7 @@ public void send(Handler<AsyncResult<Void>> completionHandler) {
229229
// Special handling for HTTP 1.0 clients that cannot handle chunked encoding
230230
// we need to buffer the content
231231
BufferingWriteStream buffer = new BufferingWriteStream();
232-
body.stream().pipeTo(buffer, ar -> {
232+
body.stream().pipeTo(buffer).onComplete(ar -> {
233233
if (ar.succeeded()) {
234234
Buffer content = buffer.content();
235235
proxiedResponse.end(content).onComplete(completionHandler);

0 commit comments

Comments
 (0)