public final class SorterFunction<T> implements Function<List<T>, List<T>> {

    final Comparator<? super T> comparator;

    public SorterFunction(Comparator<? super T> comparator) {
        this.comparator = comparator;
    }


            

Reported by PMD.

              
import org.reactivestreams.Subscriber;

import io.reactivex.rxjava3.core.*;
import io.reactivex.rxjava3.internal.subscribers.SinglePostCompleteSubscriber;
import io.reactivex.rxjava3.plugins.RxJavaPlugins;

public final class FlowableMaterialize<T> extends AbstractFlowableWithUpstream<T, Notification<T>> {


            

Reported by PMD.

              public final class CancellableQueueFuseable<T>
extends AbstractEmptyQueueFuseable<T> {

    volatile boolean disposed;

    @Override
    public void cancel() {
        disposed = true;
    }

            

Reported by PMD.

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

    @Override

            

Reported by PMD.

              
import java.util.*;

import io.reactivex.rxjava3.functions.*;

public final class TestingHelper {

    private TestingHelper() {
        // prevent instantiation

            

Reported by PMD.

                      inner.request(1);
        inner.request(1);

        assertEquals(Arrays.asList(4L, 3L), requests);
    }
}

            

Reported by PMD.

                  public Publisher<List<Long>> createPublisher(long elements) {
        return
            Flowable.fromIterable(iterate(elements))
            .window(Flowable.just(1).concatWith(Flowable.<Integer>never()))
            .onBackpressureBuffer()
            .flatMap((Function)Functions.identity())
        ;
    }
}

            

Reported by PMD.

                  @Override
    public Publisher<Long> createPublisher(final long elements) {
        return
                Flowable.timer(1, TimeUnit.MILLISECONDS)
                .onBackpressureLatest()
            ;
    }

    @Override

            

Reported by PMD.

              
    @Override
    public void subscribe(Subscriber<? super Object>[] subscribers) {
        TestException ex = new TestException();
        for (Subscriber<? super Object> s : subscribers) {
            EmptySubscription.error(ex, s);
            s.onError(ex);
            s.onNext(0);
            s.onComplete();

            

Reported by PMD.

                  @Override
    public Publisher<Long> createPublisher(long elements) {
        return
            Flowable.just(1).switchMap(Functions.justFunction(
                    Flowable.fromIterable(iterate(elements)))
            )
        ;
    }
}

            

Reported by PMD.