Removed wrong call to RxJavaPlugins.onError if PublishFlow.onError is called for multiple subscriptions
@@ -92,7 +92,9 @@ public abstract class MqttIncomingPublishFlow extends FlowWithEventLoop
@Override
public void onError(final @NotNull Throwable t) {
if (done) {
+ if (t != error) {
RxJavaPlugins.onError(t);
+ }
return;
}
error = t;
