package io.reactivex.rxjava3.internal.fuseable;

import io.reactivex.rxjava3.annotations.*;

/**
 * Override of the SimpleQueue interface with no throws Exception on poll().
 *
 * @param <T> the value type to offer and poll, not null

            

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 CompletableNever extends Completable {
    public static final Completable INSTANCE = new CompletableNever();


            

Reported by PMD.

               */
public abstract class DisposableSingleObserver<T> implements SingleObserver<T>, Disposable {

    final AtomicReference<Disposable> upstream = new AtomicReference<>();

    @Override
    public final void onSubscribe(@NonNull Disposable d) {
        if (EndConsumerHelper.setOnce(this.upstream, d, getClass())) {
            onStart();

            

Reported by PMD.

               */
final class DisposeOnCancel implements Future<Object> {

    final Disposable upstream;

    DisposeOnCancel(Disposable d) {
        this.upstream = d;
    }


            

Reported by PMD.

                  protected void onDisposed(@NonNull AutoCloseable value) {
        try {
            value.close();
        } catch (Throwable ex) {
            throw ExceptionHelper.wrapOrThrow(ex);
        }
    }

    @Override

            

Reported by PMD.

              
import io.reactivex.rxjava3.annotations.NonNull;
import io.reactivex.rxjava3.core.Scheduler;
import io.reactivex.rxjava3.disposables.*;

/**
 * A Scheduler partially implementing the API by allowing only non-delayed, non-periodic
 * task execution on the current thread immediately.
 * <p>

            

Reported by PMD.

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

import io.reactivex.rxjava3.core.*;

/**
 * Wraps a MaybeSource without safeguard and calls its subscribe() method for each MaybeObserver.
 *
 * @param <T> the value type

            

Reported by PMD.

               */
public abstract class DisposableMaybeObserver<T> implements MaybeObserver<T>, Disposable {

    final AtomicReference<Disposable> upstream = new AtomicReference<>();

    @Override
    public final void onSubscribe(@NonNull Disposable d) {
        if (EndConsumerHelper.setOnce(this.upstream, d, getClass())) {
            onStart();

            

Reported by PMD.

               */
public final class NewThreadScheduler extends Scheduler {

    final ThreadFactory threadFactory;

    private static final String THREAD_NAME_PREFIX = "RxNewThreadScheduler";
    private static final RxThreadFactory THREAD_FACTORY;

    /** The name of the system property for setting the thread priority for this Scheduler. */

            

Reported by PMD.

               */
public abstract class DisposableCompletableObserver implements CompletableObserver, Disposable {

    final AtomicReference<Disposable> upstream = new AtomicReference<>();

    @Override
    public final void onSubscribe(@NonNull Disposable d) {
        if (EndConsumerHelper.setOnce(this.upstream, d, getClass())) {
            onStart();

            

Reported by PMD.