From 7c4165d4a98f790366f22c108a5ff4107026c5a9 Mon Sep 17 00:00:00 2001 From: franz1981 Date: Sat, 26 Nov 2022 00:07:40 +0100 Subject: [PATCH] No need to use response methods returning a Future, if not used (part II) --- .../server/vertx/ResteasyReactiveOutputStream.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/independent-projects/resteasy-reactive/server/vertx/src/main/java/org/jboss/resteasy/reactive/server/vertx/ResteasyReactiveOutputStream.java b/independent-projects/resteasy-reactive/server/vertx/src/main/java/org/jboss/resteasy/reactive/server/vertx/ResteasyReactiveOutputStream.java index 7d8b00d4faaee..e3f9a68310b49 100644 --- a/independent-projects/resteasy-reactive/server/vertx/src/main/java/org/jboss/resteasy/reactive/server/vertx/ResteasyReactiveOutputStream.java +++ b/independent-projects/resteasy-reactive/server/vertx/src/main/java/org/jboss/resteasy/reactive/server/vertx/ResteasyReactiveOutputStream.java @@ -80,7 +80,7 @@ Buffer createBuffer(ByteBuf data) { public void write(ByteBuf data, boolean last) throws IOException { if (last && data == null) { - request.response().end(); + request.response().end((Handler>) null); return; } //do all this in the same lock @@ -104,9 +104,9 @@ public void write(ByteBuf data, boolean last) throws IOException { data.release(); } else { if (last) { - request.response().end(createBuffer(data)); + request.response().end(createBuffer(data), null); } else { - request.response().write(createBuffer(data)); + request.response().write(createBuffer(data), null); } } } catch (Exception e) { @@ -160,9 +160,9 @@ public void handle(Void event) { if (overflow != null) { if (overflow.size() > 0) { if (closed) { - request.response().end(Buffer.buffer(overflow.toByteArray())); + request.response().end(Buffer.buffer(overflow.toByteArray()), null); } else { - request.response().write(Buffer.buffer(overflow.toByteArray())); + request.response().write(Buffer.buffer(overflow.toByteArray()), null); } overflow.reset(); }