AbstractWriteClient lines 179-184:
.subscribe(responseNotification -> {
if (responseNotification.isOnError()) {
publish(new WriteErrorEvent(toInfluxException(responseNotification.getError())));
}
}, throwable -> new WriteErrorEvent(toInfluxException(throwable)));The latter WriteErrorEvent on line 184 never gets published.
Shouldn't the above code be:
.subscribe(responseNotification -> {
if (responseNotification.isOnError()) {
publish(new WriteErrorEvent(toInfluxException(responseNotification.getError())));
}
}, throwable -> publish(new WriteErrorEvent(toInfluxException(throwable))));Steps to reproduce:
List the minimal actions needed to reproduce the behavior.
- Create new WriteApi
- Write some points
- Wait for the throwable to trigger for some reason
Expected behavior:
A new WriteErrorEvent would be published so that event handlers can handle it
Actual behavior:
The throwable never gets published as WriteErrorEvent
Specifications:
- Client Version: 4.0.0
- InfluxDB Version: 2.1
- JDK Version: 8
- Platform:
AbstractWriteClientlines 179-184:The latter
WriteErrorEventon line 184 never getspublished.Shouldn't the above code be:
Steps to reproduce:
List the minimal actions needed to reproduce the behavior.
Expected behavior:
A new
WriteErrorEventwould be published so that event handlers can handle itActual behavior:
The throwable never gets published as
WriteErrorEventSpecifications: