*/
public final class ObservableJust<T> extends Observable<T> implements ScalarSupplier<T> {

    private final T value;
    public ObservableJust(final T value) {
        this.value = value;
    }

    @Override

            

Reported by PMD.

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

import io.reactivex.rxjava3.core.*;
import io.reactivex.rxjava3.internal.fuseable.ScalarSupplier;
import io.reactivex.rxjava3.internal.operators.observable.ObservableScalarXMap.ScalarDisposable;

/**
 * Represents a constant scalar value.

            

Reported by PMD.

              public class FlowableInternalHelperTest extends RxJavaTest {

    @Test
    public void utilityClass() {
        TestHelper.checkUtilityClass(FlowableInternalHelper.class);
    }

    @Test
    public void requestMaxEnum() {

            

Reported by PMD.

                  }

    @Test
    public void requestMaxEnum() {
        TestHelper.checkEnum(FlowableInternalHelper.RequestMax.class);
    }
}

            

Reported by PMD.

              public class CompletableToFlowableTest extends RxJavaTest {

    @Test
    public void doubleOnSubscribe() {
        TestHelper.checkDoubleOnSubscribeCompletableToFlowable(new Function<Completable, Publisher<?>>() {
            @Override
            public Publisher<?> apply(Completable c) throws Exception {
                return c.toFlowable();
            }

            

Reported by PMD.

              import org.junit.Test;
import org.reactivestreams.Publisher;

import io.reactivex.rxjava3.core.*;
import io.reactivex.rxjava3.functions.Function;
import io.reactivex.rxjava3.testsupport.TestHelper;

public class CompletableToFlowableTest extends RxJavaTest {


            

Reported by PMD.

              
import io.reactivex.rxjava3.testsupport.SuppressUndeliverableRule;

public abstract class RxJavaTest {
    @Rule
    public Timeout globalTimeout = new Timeout(5, TimeUnit.MINUTES);
    @Rule
    public final SuppressUndeliverableRule suppressUndeliverableRule = new SuppressUndeliverableRule();


            

Reported by PMD.

              
import java.util.concurrent.TimeUnit;

import org.junit.*;
import org.junit.rules.Timeout;

import io.reactivex.rxjava3.testsupport.SuppressUndeliverableRule;

public abstract class RxJavaTest {

            

Reported by PMD.

              public class MaybeMapTest extends RxJavaTest {

    @Test
    public void doubleOnSubscribe() {
        TestHelper.checkDoubleOnSubscribeMaybe(new Function<Maybe<Object>, MaybeSource<Object>>() {
            @Override
            public MaybeSource<Object> apply(Maybe<Object> m) throws Exception {
                return m.map(Functions.identity());
            }

            

Reported by PMD.

              
import org.junit.Test;

import io.reactivex.rxjava3.core.*;
import io.reactivex.rxjava3.functions.Function;
import io.reactivex.rxjava3.internal.functions.Functions;
import io.reactivex.rxjava3.testsupport.TestHelper;

public class MaybeMapTest extends RxJavaTest {

            

Reported by PMD.

              
package io.reactivex.rxjava3.flowable;

import org.junit.*;

import io.reactivex.rxjava3.core.*;

public class FlowableNotificationTest extends RxJavaTest {


            

Reported by PMD.

              
import org.junit.*;

import io.reactivex.rxjava3.core.*;

public class FlowableNotificationTest extends RxJavaTest {

    @Test(expected = NullPointerException.class)
    public void onNextIntegerNotificationDoesNotEqualNullNotification() {

            

Reported by PMD.

              public class MaybeErrorTest extends RxJavaTest {

    @Test
    public void errorSupplierThrows() {
        Maybe.error(new Supplier<Throwable>() {
            @Override
            public Throwable get() throws Exception {
                throw new TestException();
            }

            

Reported by PMD.

              
import org.junit.Test;

import io.reactivex.rxjava3.core.*;
import io.reactivex.rxjava3.exceptions.TestException;
import io.reactivex.rxjava3.functions.Supplier;

public class MaybeErrorTest extends RxJavaTest {


            

Reported by PMD.

              
    @Override
    public Publisher<Integer> createFailedPublisher() {
        return Flowable.just(1).<Integer>mapOptional(v -> null).onBackpressureDrop();
    }
}

            

Reported by PMD.

              
    @Override
    public Publisher<Integer> createFailedPublisher() {
        return Flowable.just(1).<Integer>mapOptional(v -> null).onBackpressureDrop();
    }
}

            

Reported by PMD.

              
package io.reactivex.rxjava3.subjects;

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

/**
 * Represents an {@link Observer} and an {@link Observable} at the same time, allowing
 * multicasting events from a single source to multiple child {@code Observer}s.

            

Reported by PMD.

              package io.reactivex.rxjava3.subjects;

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

/**
 * Represents an {@link Observer} and an {@link Observable} at the same time, allowing
 * multicasting events from a single source to multiple child {@code Observer}s.
 * <p>

            

Reported by PMD.

                  @Override
    public Publisher<Integer> createFailedPublisher() {
        Stream<Integer> stream = Stream.of(1);
        stream.forEach(v -> { });
        return Flowable.just(1).flatMapStream(v -> stream);
    }
}

            

Reported by PMD.

                  public Publisher<Integer> createFailedPublisher() {
        Stream<Integer> stream = Stream.of(1);
        stream.forEach(v -> { });
        return Flowable.just(1).flatMapStream(v -> stream);
    }
}

            

Reported by PMD.