Skip to content

Commit 718238e

Browse files
committed
Removed wrong call to RxJavaPlugins.onError if PublishFlow.onError is called for multiple subscriptions
1 parent 6e15f5c commit 718238e

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

src/main/java/com/hivemq/client/internal/mqtt/handler/publish/incoming/MqttIncomingPublishFlow.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -92,7 +92,9 @@ public void onComplete() {
9292
@Override
9393
public void onError(final @NotNull Throwable t) {
9494
if (done) {
95-
RxJavaPlugins.onError(t);
95+
if (t != error) {
96+
RxJavaPlugins.onError(t);
97+
}
9698
return;
9799
}
98100
error = t;

0 commit comments

Comments
 (0)