public static void onError(Subscriber<?> subscriber, Throwable ex,
            AtomicInteger wip, AtomicThrowable errors) {
        if (errors.tryAddThrowableOrReport(ex)) {
            if (wip.getAndIncrement() == 0) {
                errors.tryTerminateConsumer(subscriber);
            }
        }
    }


            

Reported by PMD.

                  public static void onError(Observer<?> observer, Throwable ex,
            AtomicInteger wip, AtomicThrowable errors) {
        if (errors.tryAddThrowableOrReport(ex)) {
            if (wip.getAndIncrement() == 0) {
                errors.tryTerminateConsumer(observer);
            }
        }
    }


            

Reported by PMD.

              
import org.reactivestreams.Processor;

import io.reactivex.rxjava3.annotations.*;
import io.reactivex.rxjava3.core.*;

/**
 * Represents a Subscriber and a Flowable (Publisher) at the same time, allowing
 * multicasting events from a single source to multiple child Subscribers.

            

Reported by PMD.

              import org.reactivestreams.Processor;

import io.reactivex.rxjava3.annotations.*;
import io.reactivex.rxjava3.core.*;

/**
 * Represents a Subscriber and a Flowable (Publisher) at the same time, allowing
 * multicasting events from a single source to multiple child Subscribers.
 * <p>All methods except the onSubscribe, onNext, onError and onComplete are thread-safe.

            

Reported by PMD.

               */
public final class FlowableFromRunnable<T> extends Flowable<T> implements Supplier<T> {

    final Runnable run;

    public FlowableFromRunnable(Runnable run) {
        this.run = run;
    }


            

Reported by PMD.

              
            try {
                run.run();
            } catch (Throwable ex) {
                Exceptions.throwIfFatal(ex);
                if (!qs.isDisposed()) {
                    subscriber.onError(ex);
                } else {
                    RxJavaPlugins.onError(ex);

            

Reported by PMD.

               */
public final class ObservableFirstStageObserver<T> extends ObservableStageObserver<T> {

    final boolean hasDefault;

    final T defaultItem;

    public ObservableFirstStageObserver(boolean hasDefault, T defaultItem) {
        this.hasDefault = hasDefault;

            

Reported by PMD.

              
    final boolean hasDefault;

    final T defaultItem;

    public ObservableFirstStageObserver(boolean hasDefault, T defaultItem) {
        this.hasDefault = hasDefault;
        this.defaultItem = defaultItem;
    }

            

Reported by PMD.

              import io.reactivex.rxjava3.core.*;

public final class SingleFromUnsafeSource<T> extends Single<T> {
    final SingleSource<T> source;

    public SingleFromUnsafeSource(SingleSource<T> source) {
        this.source = source;
    }


            

Reported by PMD.

              
package io.reactivex.rxjava3.internal.operators.single;

import io.reactivex.rxjava3.core.*;

public final class SingleFromUnsafeSource<T> extends Single<T> {
    final SingleSource<T> source;

    public SingleFromUnsafeSource(SingleSource<T> source) {

            

Reported by PMD.

              
public final class CompletableError extends Completable {

    final Throwable error;

    public CompletableError(Throwable error) {
        this.error = error;
    }


            

Reported by PMD.

              
package io.reactivex.rxjava3.internal.operators.completable;

import io.reactivex.rxjava3.core.*;
import io.reactivex.rxjava3.internal.disposables.EmptyDisposable;

public final class CompletableError extends Completable {

    final Throwable error;

            

Reported by PMD.

               */
final class FlowableWindowSubscribeIntercept<T> extends Flowable<T> {

    final FlowableProcessor<T> window;

    final AtomicBoolean once;

    FlowableWindowSubscribeIntercept(FlowableProcessor<T> source) {
        this.window = source;

            

Reported by PMD.

              
    final FlowableProcessor<T> window;

    final AtomicBoolean once;

    FlowableWindowSubscribeIntercept(FlowableProcessor<T> source) {
        this.window = source;
        this.once = new AtomicBoolean();
    }

            

Reported by PMD.

              
public final class SingleJust<T> extends Single<T> {

    final T value;

    public SingleJust(T value) {
        this.value = value;
    }


            

Reported by PMD.

              
package io.reactivex.rxjava3.internal.operators.single;

import io.reactivex.rxjava3.core.*;
import io.reactivex.rxjava3.disposables.Disposable;

public final class SingleJust<T> extends Single<T> {

    final T value;

            

Reported by PMD.

               */
public final class SingleMaterialize<T> extends Single<Notification<T>> {

    final Single<T> source;

    public SingleMaterialize(Single<T> source) {
        this.source = source;
    }


            

Reported by PMD.

              
package io.reactivex.rxjava3.internal.operators.single;

import io.reactivex.rxjava3.core.*;
import io.reactivex.rxjava3.internal.operators.mixed.MaterializeSingleObserver;

/**
 * Turn the signal types of a Single source into a single Notification of
 * equal kind.

            

Reported by PMD.

               */
public final class MaybeError<T> extends Maybe<T> {

    final Throwable error;

    public MaybeError(Throwable error) {
        this.error = error;
    }


            

Reported by PMD.

              
package io.reactivex.rxjava3.internal.operators.maybe;

import io.reactivex.rxjava3.core.*;
import io.reactivex.rxjava3.disposables.Disposable;

/**
 * Signals a constant Throwable.
 *

            

Reported by PMD.