package io.reactivex.rxjava3.internal.disposables;

import io.reactivex.rxjava3.annotations.Nullable;
import io.reactivex.rxjava3.core.*;
import io.reactivex.rxjava3.internal.fuseable.QueueDisposable;

/**
 * Represents a stateless empty Disposable that reports being always
 * empty and disposed.

            

Reported by PMD.

               * @param <T> the value type
 */
public final class FlowableJust<T> extends Flowable<T> implements ScalarSupplier<T> {
    private final T value;
    public FlowableJust(final T value) {
        this.value = value;
    }

    @Override

            

Reported by PMD.

              
import java.util.*;

import io.reactivex.rxjava3.functions.*;

public enum ArrayListSupplier implements Supplier<List<Object>>, Function<Object, List<Object>> {
    INSTANCE;

    @SuppressWarnings({ "unchecked", "rawtypes" })

            

Reported by PMD.

              
import org.reactivestreams.Subscriber;

import io.reactivex.rxjava3.core.*;
import io.reactivex.rxjava3.plugins.RxJavaPlugins;

/**
 * Atomic container for Throwables including combining and having a
 * terminal state via ExceptionHelper.

            

Reported by PMD.

                                  return defaultNotFound;
                }
                return "true".equals(value);
            } catch (Throwable ex) {
                Exceptions.throwIfFatal(ex);
                return defaultNotFound;
            }
        }
        return defaultNotEnabled;

            

Reported by PMD.

              
package io.reactivex.rxjava3.internal.fuseable;

import io.reactivex.rxjava3.annotations.*;

/**
 * A minimalist queue interface without the method bloat of java.util.Collection and java.util.Queue.
 *
 * @param <T> the value type to offer and poll, not null

            

Reported by PMD.

              
package io.reactivex.rxjava3.core;

import io.reactivex.rxjava3.annotations.*;
import io.reactivex.rxjava3.disposables.Disposable;
import io.reactivex.rxjava3.functions.Cancellable;

/**
 * Abstraction over an RxJava {@link CompletableObserver} that allows associating

            

Reported by PMD.

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

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

public final class ObservableEmpty extends Observable<Object> implements ScalarSupplier<Object> {
    public static final Observable<Object> INSTANCE = new ObservableEmpty();

            

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


            

Reported by PMD.

              
package io.reactivex.rxjava3.core;

import org.reactivestreams.*;

import io.reactivex.rxjava3.annotations.NonNull;

/**
 * Represents a Reactive-Streams inspired {@link Subscriber} that is RxJava 3 only

            

Reported by PMD.