Imporve vert.x rx error handling
MODIFY
instrumentation/vertx-reactive-3.5/javaagent/src/latestDepTest/groovy/client/VertxRxCircuitBreakerWebClientTest.groovy
instrumentation/vertx-reactive-3.5/javaagent/src/latestDepTest/groovy/client/VertxRxCircuitBreakerWebClientTest.groovy
@@ -62,11 +62,11 @@ class VertxRxCircuitBreakerWebClientTest extends HttpClientTest<HttpRequest<?>>
void sendRequestWithCallback(HttpRequest<?> request, Consumer<AsyncResult> consumer) {
breaker.execute({ command ->
- request.rxSend().doOnSuccess {
- command.complete(it)
- }.doOnError {
- command.fail(it)
- }.subscribe()
+ request.rxSend().subscribe({ response ->
+ command.complete(response)
+ }, { throwable ->
+ command.fail(throwable)
+ })
}, {
consumer.accept(it)
})

MODIFY
instrumentation/vertx-reactive-3.5/javaagent/src/version35Test/groovy/client/VertxRxCircuitBreakerWebClientTest.groovy
instrumentation/vertx-reactive-3.5/javaagent/src/version35Test/groovy/client/VertxRxCircuitBreakerWebClientTest.groovy
@@ -63,11 +63,11 @@ class VertxRxCircuitBreakerWebClientTest extends HttpClientTest<HttpRequest<?>>
void sendRequestWithCallback(HttpRequest<?> request, Consumer<AsyncResult> consumer) {
breaker.executeCommand({ command ->
- request.rxSend().doOnSuccess {
- command.complete(it)
- }.doOnError {
- command.fail(it)
- }.subscribe()
+ request.rxSend().subscribe({ response ->
+ command.complete(response)
+ }, { throwable ->
+ command.fail(throwable)
+ })
}, {
consumer.accept(it)
})

Imporve vert.x rx error handling (#4845)