Repository: quarkusio/quarkus
Issue: Reactive Client - Mutiny Dropped Exception on Cancel (stream+json)

### Describe the bug

After canceling a subscription to a Multi from the reactive client, I see error logs like

`2023-04-27 11:51:47,838 ERROR [io.qua.mut.run.MutinyInfrastructure] (vert.x-eventloop-thread-0) Mutiny had to drop the following exception: io.vertx.core.http.HttpClosedException: Connection was closed`

This error log looks identical to what was seen in https://github.com/quarkusio/quarkus/issues/27489 and fixed in a PR linked in that issue, but it is occurring in my code. The difference seems to be that my client is dealing with these media types
```
@Produces(RestMediaType.APPLICATION_STREAM_JSON)
@RestStreamElementType(MediaType.APPLICATION_JSON)
```
rather than `MediaType.SERVER_SENT_EVENTS`

### Expected behavior

The `Cancellable` will cancel gracefully/without lingering error logs in the client

### Actual behavior

error logs as copied in description

### How to Reproduce?

Reproducer: `service3` (client) and `service4` (server) in https://github.com/fleckware/quarkus-test
1. in one terminal `./gradlew service4:quarkusDev`
2. in a separate terminal `./gradlew service3:quarkusDev`
3. in a separate terminal `curl localhost:8080/service3/test/cancel`

It sleeps for 10 seconds before trying to cancel, then observe error logs in client

### Output of `uname -a` or `ver`

_No response_

### Output of `java -version`

openjdk 11.0.10

### GraalVM version (if different from Java)

_No response_

### Quarkus version or git rev

3.0.0

### Build tool (ie. output of `mvnw --version` or `gradlew --version`)

gradle 7.4.2

### Additional information

_No response_

Changed files:
independent-projects/resteasy-reactive/client/runtime/src/main/java/org/jboss/resteasy/reactive/client/impl/MultiInvoker.java

diff --git a/independent-projects/resteasy-reactive/client/runtime/src/main/java/org/jboss/resteasy/reactive/client/impl/MultiInvoker.java b/independent-projects/resteasy-reactive/client/runtime/src/main/java/org/jboss/resteasy/reactive/client/impl/MultiInvoker.java
index e84f30da72e..9a0efc53b29 100644
--- a/independent-projects/resteasy-reactive/client/runtime/src/main/java/org/jboss/resteasy/reactive/client/impl/MultiInvoker.java
+++ b/independent-projects/resteasy-reactive/client/runtime/src/main/java/org/jboss/resteasy/reactive/client/impl/MultiInvoker.java
@@ -241,7 +241,6 @@ public void handle(Buffer buffer) {
         });
 
         // this captures the end of the response
-        // FIXME: won't this call complete twice()?
         vertxClientResponse.endHandler(v -> {
             multiRequest.emitter.complete();
         });
@@ -265,9 +264,9 @@ public void handle(Buffer chunk) {
                 try {
                     R item = restClientRequestContext.readEntity(in, responseType, response.getMediaType(),
                             response.getMetadata());
-                    multiRequest.emitter.emit(item);
+                    multiRequest.emit(item);
                 } catch (IOException e) {
-                    multiRequest.emitter.fail(e);
+                    multiRequest.fail(e);
                 }
             }
         });
@@ -275,7 +274,7 @@ public void handle(Buffer chunk) {
             if (t == ConnectionBase.CLOSED_EXCEPTION) {
                 // we can ignore this one since we registered a closeHandler
             } else {
-                multiRequest.emitter.fail(t);
+                multiRequest.fail(t);
             }
         });
         vertxClientResponse.endHandler(new Handler<Void>() {