public class MaybeConcatArrayEagerDelayErrorTest {

    @Test
    public void normal() {
        Maybe.concatArrayEagerDelayError(
                Maybe.just(1),
                Maybe.<Integer>error(new TestException()),
                Maybe.empty(),
                Maybe.just(2)

            

Reported by PMD.

              public class SingleConcatArrayDelayErrorTest {

    @Test
    public void normal() {
        Single.concatArrayDelayError(
                Single.just(1),
                Single.<Integer>error(new TestException()),
                Single.just(2)
        )

            

Reported by PMD.

              public class InnerQueuedObserverTest extends RxJavaTest {

    @Test
    public void dispose() {
        TestHelper.checkDisposed(new InnerQueuedObserver<>(null, 1));
    }
}

            

Reported by PMD.

                  public void defaultShouldReportNoCustomOnError() {
        EmptyCompletableObserver o = new EmptyCompletableObserver();

        assertFalse(o.hasCustomOnError());
    }
}

            

Reported by PMD.

              
            Scheduler.Worker worker = Schedulers.single().createWorker();

            DisposeTask task = new DisposeTask(() -> {
                throw new TestException();
            }, worker);

            try {
                task.run();

            

Reported by PMD.

              
public class FlowableEventStreamTest extends RxJavaTest {
    @Test
    public void constructorShouldBePrivate() {
        TestHelper.checkUtilityClass(FlowableEventStream.class);
    }
}

            

Reported by PMD.

              
public class BasicQueueDisposableTest extends RxJavaTest {

    BasicQueueDisposable<Integer> q = new BasicQueueDisposable<Integer>() {

        @Override
        public boolean isDisposed() {
            return false;
        }

            

Reported by PMD.

              
    public static final Object TERMINATED = new Object();

    final Queue<Object> queue;

    public BlockingObserver(Queue<Object> queue) {
        this.queue = queue;
    }


            

Reported by PMD.

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

import io.reactivex.rxjava3.core.*;
import io.reactivex.rxjava3.observers.SerializedObserver;

public final class ObservableSerialized<T> extends AbstractObservableWithUpstream<T, T> {
    public ObservableSerialized(Observable<T> upstream) {
        super(upstream);

            

Reported by PMD.

              
    @Override
    public void onError(Throwable t) {
        value = null;
        error = t;
        countDown();
    }
}

            

Reported by PMD.