The following issues were found
src/test/java/io/reactivex/rxjava3/internal/operators/completable/CompletableDoOnTest.java
19 issues
Line: 33
public class CompletableDoOnTest extends RxJavaTest {
@Test
public void successAcceptThrows() {
Completable.complete().doOnEvent(new Consumer<Throwable>() {
@Override
public void accept(Throwable e) throws Exception {
throw new TestException();
}
Reported by PMD.
Line: 45
}
@Test
public void errorAcceptThrows() {
TestObserverEx<Void> to = Completable.error(new TestException("Outer")).doOnEvent(new Consumer<Throwable>() {
@Override
public void accept(Throwable e) throws Exception {
throw new TestException("Inner");
}
Reported by PMD.
Line: 55
.to(TestHelper.<Void>testConsumer())
.assertFailure(CompositeException.class);
List<Throwable> errors = TestHelper.compositeList(to.errors().get(0));
TestHelper.assertError(errors, 0, TestException.class, "Outer");
TestHelper.assertError(errors, 1, TestException.class, "Inner");
}
Reported by PMD.
Line: 62
}
@Test
public void doOnDisposeCalled() {
final AtomicBoolean atomicBoolean = new AtomicBoolean();
assertFalse(atomicBoolean.get());
Completable.complete()
Reported by PMD.
Line: 65
public void doOnDisposeCalled() {
final AtomicBoolean atomicBoolean = new AtomicBoolean();
assertFalse(atomicBoolean.get());
Completable.complete()
.doOnDispose(new Action() {
@Override
public void run() throws Exception {
Reported by PMD.
Line: 78
.assertResult()
.dispose();
assertTrue(atomicBoolean.get());
}
@Test
public void onSubscribeCrash() {
List<Throwable> errors = TestHelper.trackPluginErrors();
Reported by PMD.
Line: 104
.to(TestHelper.<Void>testConsumer())
.assertFailureAndMessage(TestException.class, "First");
assertTrue(bs.isDisposed());
TestHelper.assertUndeliverable(errors, 0, TestException.class, "Second");
} finally {
RxJavaPlugins.reset();
}
Reported by PMD.
Line: 104
.to(TestHelper.<Void>testConsumer())
.assertFailureAndMessage(TestException.class, "First");
assertTrue(bs.isDisposed());
TestHelper.assertUndeliverable(errors, 0, TestException.class, "Second");
} finally {
RxJavaPlugins.reset();
}
Reported by PMD.
Line: 16
package io.reactivex.rxjava3.internal.operators.completable;
import static org.junit.Assert.*;
import java.util.List;
import java.util.concurrent.atomic.AtomicBoolean;
import org.junit.Test;
Reported by PMD.
Line: 23
import org.junit.Test;
import io.reactivex.rxjava3.core.*;
import io.reactivex.rxjava3.disposables.*;
import io.reactivex.rxjava3.exceptions.*;
import io.reactivex.rxjava3.functions.*;
import io.reactivex.rxjava3.plugins.RxJavaPlugins;
import io.reactivex.rxjava3.testsupport.*;
Reported by PMD.
src/test/java/io/reactivex/rxjava3/disposables/SerialDisposableTests.java
19 issues
Line: 31
@RunWith(MockitoJUnitRunner.class)
public class SerialDisposableTests extends RxJavaTest {
private SerialDisposable serialDisposable;
@Before
public void setUp() {
serialDisposable = new SerialDisposable();
}
Reported by PMD.
Line: 44
}
@Test
public void getDisposableShouldReturnset() {
final Disposable underlying = mock(Disposable.class);
serialDisposable.set(underlying);
assertSame(underlying, serialDisposable.get());
final Disposable another = mock(Disposable.class);
Reported by PMD.
Line: 62
serialDisposable.replace(Disposable.empty());
serialDisposable.dispose();
verify(underlying, never()).dispose();
}
@Test
public void unsubscribingTwiceDoesUnsubscribeOnce() {
Disposable underlying = mock(Disposable.class);
Reported by PMD.
Line: 71
serialDisposable.set(underlying);
serialDisposable.dispose();
verify(underlying).dispose();
serialDisposable.dispose();
verifyNoMoreInteractions(underlying);
}
Reported by PMD.
Line: 83
serialDisposable.set(underlying);
verifyNoInteractions(underlying);
serialDisposable.set(underlying);
verify(underlying).dispose();
}
@Test
public void unsubscribingWithSingleUnderlyingUnsubscribes() {
Disposable underlying = mock(Disposable.class);
Reported by PMD.
Line: 90
public void unsubscribingWithSingleUnderlyingUnsubscribes() {
Disposable underlying = mock(Disposable.class);
serialDisposable.set(underlying);
underlying.dispose();
verify(underlying).dispose();
}
@Test
public void replacingFirstUnderlyingCausesUnsubscription() {
Reported by PMD.
Line: 91
Disposable underlying = mock(Disposable.class);
serialDisposable.set(underlying);
underlying.dispose();
verify(underlying).dispose();
}
@Test
public void replacingFirstUnderlyingCausesUnsubscription() {
Disposable first = mock(Disposable.class);
Reported by PMD.
Line: 100
serialDisposable.set(first);
Disposable second = mock(Disposable.class);
serialDisposable.set(second);
verify(first).dispose();
}
@Test
public void whenUnsubscribingSecondUnderlyingUnsubscribed() {
Disposable first = mock(Disposable.class);
Reported by PMD.
Line: 110
Disposable second = mock(Disposable.class);
serialDisposable.set(second);
serialDisposable.dispose();
verify(second).dispose();
}
@Test
public void settingUnderlyingWhenUnsubscribedCausesImmediateUnsubscription() {
serialDisposable.dispose();
Reported by PMD.
Line: 118
serialDisposable.dispose();
Disposable underlying = mock(Disposable.class);
serialDisposable.set(underlying);
verify(underlying).dispose();
}
@Test
public void settingUnderlyingWhenUnsubscribedCausesImmediateUnsubscriptionConcurrently()
throws InterruptedException {
Reported by PMD.
src/test/java/io/reactivex/rxjava3/internal/operators/flowable/FlowableHideTest.java
19 issues
Line: 34
public void hiding() {
PublishProcessor<Integer> src = PublishProcessor.create();
Flowable<Integer> dst = src.hide();
assertFalse(dst instanceof PublishProcessor);
Subscriber<Object> subscriber = TestHelper.mockSubscriber();
Reported by PMD.
Line: 36
Flowable<Integer> dst = src.hide();
assertFalse(dst instanceof PublishProcessor);
Subscriber<Object> subscriber = TestHelper.mockSubscriber();
dst.subscribe(subscriber);
Reported by PMD.
Line: 40
Subscriber<Object> subscriber = TestHelper.mockSubscriber();
dst.subscribe(subscriber);
src.onNext(1);
src.onComplete();
verify(subscriber).onNext(1);
Reported by PMD.
Line: 42
dst.subscribe(subscriber);
src.onNext(1);
src.onComplete();
verify(subscriber).onNext(1);
verify(subscriber).onComplete();
verify(subscriber, never()).onError(any(Throwable.class));
Reported by PMD.
Line: 43
dst.subscribe(subscriber);
src.onNext(1);
src.onComplete();
verify(subscriber).onNext(1);
verify(subscriber).onComplete();
verify(subscriber, never()).onError(any(Throwable.class));
}
Reported by PMD.
Line: 45
src.onNext(1);
src.onComplete();
verify(subscriber).onNext(1);
verify(subscriber).onComplete();
verify(subscriber, never()).onError(any(Throwable.class));
}
@Test
Reported by PMD.
Line: 46
src.onComplete();
verify(subscriber).onNext(1);
verify(subscriber).onComplete();
verify(subscriber, never()).onError(any(Throwable.class));
}
@Test
public void hidingError() {
Reported by PMD.
Line: 47
verify(subscriber).onNext(1);
verify(subscriber).onComplete();
verify(subscriber, never()).onError(any(Throwable.class));
}
@Test
public void hidingError() {
PublishProcessor<Integer> src = PublishProcessor.create();
Reported by PMD.
Line: 54
public void hidingError() {
PublishProcessor<Integer> src = PublishProcessor.create();
Flowable<Integer> dst = src.hide();
assertFalse(dst instanceof PublishProcessor);
Subscriber<Object> subscriber = TestHelper.mockSubscriber();
Reported by PMD.
Line: 56
Flowable<Integer> dst = src.hide();
assertFalse(dst instanceof PublishProcessor);
Subscriber<Object> subscriber = TestHelper.mockSubscriber();
dst.subscribe(subscriber);
Reported by PMD.
src/test/java/io/reactivex/rxjava3/internal/operators/observable/ObservableSwitchIfEmptyTest.java
19 issues
Line: 31
public class ObservableSwitchIfEmptyTest extends RxJavaTest {
@Test
public void switchWhenNotEmpty() throws Exception {
final AtomicBoolean subscribed = new AtomicBoolean(false);
final Observable<Integer> o = Observable.just(4)
.switchIfEmpty(Observable.just(2)
.doOnSubscribe(new Consumer<Disposable>() {
@Override
Reported by PMD.
Line: 31
public class ObservableSwitchIfEmptyTest extends RxJavaTest {
@Test
public void switchWhenNotEmpty() throws Exception {
final AtomicBoolean subscribed = new AtomicBoolean(false);
final Observable<Integer> o = Observable.just(4)
.switchIfEmpty(Observable.just(2)
.doOnSubscribe(new Consumer<Disposable>() {
@Override
Reported by PMD.
Line: 42
}
}));
assertEquals(4, o.blockingSingle().intValue());
assertFalse(subscribed.get());
}
@Test
public void switchWhenEmpty() throws Exception {
Reported by PMD.
Line: 42
}
}));
assertEquals(4, o.blockingSingle().intValue());
assertFalse(subscribed.get());
}
@Test
public void switchWhenEmpty() throws Exception {
Reported by PMD.
Line: 43
}));
assertEquals(4, o.blockingSingle().intValue());
assertFalse(subscribed.get());
}
@Test
public void switchWhenEmpty() throws Exception {
final Observable<Integer> o = Observable.<Integer>empty()
Reported by PMD.
Line: 47
}
@Test
public void switchWhenEmpty() throws Exception {
final Observable<Integer> o = Observable.<Integer>empty()
.switchIfEmpty(Observable.fromIterable(Arrays.asList(42)));
assertEquals(42, o.blockingSingle().intValue());
}
Reported by PMD.
Line: 48
@Test
public void switchWhenEmpty() throws Exception {
final Observable<Integer> o = Observable.<Integer>empty()
.switchIfEmpty(Observable.fromIterable(Arrays.asList(42)));
assertEquals(42, o.blockingSingle().intValue());
}
Reported by PMD.
Line: 48
@Test
public void switchWhenEmpty() throws Exception {
final Observable<Integer> o = Observable.<Integer>empty()
.switchIfEmpty(Observable.fromIterable(Arrays.asList(42)));
assertEquals(42, o.blockingSingle().intValue());
}
Reported by PMD.
Line: 51
final Observable<Integer> o = Observable.<Integer>empty()
.switchIfEmpty(Observable.fromIterable(Arrays.asList(42)));
assertEquals(42, o.blockingSingle().intValue());
}
@Test
public void switchTriggerUnsubscribe() throws Exception {
Reported by PMD.
Line: 51
final Observable<Integer> o = Observable.<Integer>empty()
.switchIfEmpty(Observable.fromIterable(Arrays.asList(42)));
assertEquals(42, o.blockingSingle().intValue());
}
@Test
public void switchTriggerUnsubscribe() throws Exception {
Reported by PMD.
src/test/java/io/reactivex/rxjava3/internal/operators/observable/ObservableTimestampTest.java
19 issues
Line: 32
import io.reactivex.rxjava3.testsupport.TestHelper;
public class ObservableTimestampTest extends RxJavaTest {
Observer<Object> observer;
@Before
public void before() {
observer = TestHelper.mockObserver();
}
Reported by PMD.
Line: 44
TestScheduler scheduler = new TestScheduler();
PublishSubject<Integer> source = PublishSubject.create();
Observable<Timed<Integer>> m = source.timestamp(scheduler);
m.subscribe(observer);
source.onNext(1);
scheduler.advanceTimeBy(100, TimeUnit.MILLISECONDS);
source.onNext(2);
Reported by PMD.
Line: 45
PublishSubject<Integer> source = PublishSubject.create();
Observable<Timed<Integer>> m = source.timestamp(scheduler);
m.subscribe(observer);
source.onNext(1);
scheduler.advanceTimeBy(100, TimeUnit.MILLISECONDS);
source.onNext(2);
scheduler.advanceTimeBy(100, TimeUnit.MILLISECONDS);
Reported by PMD.
Line: 47
Observable<Timed<Integer>> m = source.timestamp(scheduler);
m.subscribe(observer);
source.onNext(1);
scheduler.advanceTimeBy(100, TimeUnit.MILLISECONDS);
source.onNext(2);
scheduler.advanceTimeBy(100, TimeUnit.MILLISECONDS);
source.onNext(3);
Reported by PMD.
Line: 49
source.onNext(1);
scheduler.advanceTimeBy(100, TimeUnit.MILLISECONDS);
source.onNext(2);
scheduler.advanceTimeBy(100, TimeUnit.MILLISECONDS);
source.onNext(3);
InOrder inOrder = inOrder(observer);
Reported by PMD.
Line: 51
scheduler.advanceTimeBy(100, TimeUnit.MILLISECONDS);
source.onNext(2);
scheduler.advanceTimeBy(100, TimeUnit.MILLISECONDS);
source.onNext(3);
InOrder inOrder = inOrder(observer);
inOrder.verify(observer, times(1)).onNext(new Timed<>(1, 0, TimeUnit.MILLISECONDS));
inOrder.verify(observer, times(1)).onNext(new Timed<>(2, 100, TimeUnit.MILLISECONDS));
Reported by PMD.
Line: 59
inOrder.verify(observer, times(1)).onNext(new Timed<>(2, 100, TimeUnit.MILLISECONDS));
inOrder.verify(observer, times(1)).onNext(new Timed<>(3, 200, TimeUnit.MILLISECONDS));
verify(observer, never()).onError(any(Throwable.class));
verify(observer, never()).onComplete();
}
@Test
public void timestampWithScheduler2() {
Reported by PMD.
Line: 60
inOrder.verify(observer, times(1)).onNext(new Timed<>(3, 200, TimeUnit.MILLISECONDS));
verify(observer, never()).onError(any(Throwable.class));
verify(observer, never()).onComplete();
}
@Test
public void timestampWithScheduler2() {
TestScheduler scheduler = new TestScheduler();
Reported by PMD.
Line: 68
TestScheduler scheduler = new TestScheduler();
PublishSubject<Integer> source = PublishSubject.create();
Observable<Timed<Integer>> m = source.timestamp(scheduler);
m.subscribe(observer);
source.onNext(1);
source.onNext(2);
scheduler.advanceTimeBy(100, TimeUnit.MILLISECONDS);
Reported by PMD.
Line: 69
PublishSubject<Integer> source = PublishSubject.create();
Observable<Timed<Integer>> m = source.timestamp(scheduler);
m.subscribe(observer);
source.onNext(1);
source.onNext(2);
scheduler.advanceTimeBy(100, TimeUnit.MILLISECONDS);
scheduler.advanceTimeBy(100, TimeUnit.MILLISECONDS);
Reported by PMD.
src/test/java/io/reactivex/rxjava3/internal/operators/flowable/FlowableTimestampTest.java
19 issues
Line: 33
import io.reactivex.rxjava3.testsupport.TestHelper;
public class FlowableTimestampTest extends RxJavaTest {
Subscriber<Object> subscriber;
@Before
public void before() {
subscriber = TestHelper.mockSubscriber();
}
Reported by PMD.
Line: 45
TestScheduler scheduler = new TestScheduler();
PublishProcessor<Integer> source = PublishProcessor.create();
Flowable<Timed<Integer>> m = source.timestamp(scheduler);
m.subscribe(subscriber);
source.onNext(1);
scheduler.advanceTimeBy(100, TimeUnit.MILLISECONDS);
source.onNext(2);
Reported by PMD.
Line: 46
PublishProcessor<Integer> source = PublishProcessor.create();
Flowable<Timed<Integer>> m = source.timestamp(scheduler);
m.subscribe(subscriber);
source.onNext(1);
scheduler.advanceTimeBy(100, TimeUnit.MILLISECONDS);
source.onNext(2);
scheduler.advanceTimeBy(100, TimeUnit.MILLISECONDS);
Reported by PMD.
Line: 48
Flowable<Timed<Integer>> m = source.timestamp(scheduler);
m.subscribe(subscriber);
source.onNext(1);
scheduler.advanceTimeBy(100, TimeUnit.MILLISECONDS);
source.onNext(2);
scheduler.advanceTimeBy(100, TimeUnit.MILLISECONDS);
source.onNext(3);
Reported by PMD.
Line: 50
source.onNext(1);
scheduler.advanceTimeBy(100, TimeUnit.MILLISECONDS);
source.onNext(2);
scheduler.advanceTimeBy(100, TimeUnit.MILLISECONDS);
source.onNext(3);
InOrder inOrder = inOrder(subscriber);
Reported by PMD.
Line: 52
scheduler.advanceTimeBy(100, TimeUnit.MILLISECONDS);
source.onNext(2);
scheduler.advanceTimeBy(100, TimeUnit.MILLISECONDS);
source.onNext(3);
InOrder inOrder = inOrder(subscriber);
inOrder.verify(subscriber, times(1)).onNext(new Timed<>(1, 0, TimeUnit.MILLISECONDS));
inOrder.verify(subscriber, times(1)).onNext(new Timed<>(2, 100, TimeUnit.MILLISECONDS));
Reported by PMD.
Line: 60
inOrder.verify(subscriber, times(1)).onNext(new Timed<>(2, 100, TimeUnit.MILLISECONDS));
inOrder.verify(subscriber, times(1)).onNext(new Timed<>(3, 200, TimeUnit.MILLISECONDS));
verify(subscriber, never()).onError(any(Throwable.class));
verify(subscriber, never()).onComplete();
}
@Test
public void timestampWithScheduler2() {
Reported by PMD.
Line: 61
inOrder.verify(subscriber, times(1)).onNext(new Timed<>(3, 200, TimeUnit.MILLISECONDS));
verify(subscriber, never()).onError(any(Throwable.class));
verify(subscriber, never()).onComplete();
}
@Test
public void timestampWithScheduler2() {
TestScheduler scheduler = new TestScheduler();
Reported by PMD.
Line: 69
TestScheduler scheduler = new TestScheduler();
PublishProcessor<Integer> source = PublishProcessor.create();
Flowable<Timed<Integer>> m = source.timestamp(scheduler);
m.subscribe(subscriber);
source.onNext(1);
source.onNext(2);
scheduler.advanceTimeBy(100, TimeUnit.MILLISECONDS);
Reported by PMD.
Line: 70
PublishProcessor<Integer> source = PublishProcessor.create();
Flowable<Timed<Integer>> m = source.timestamp(scheduler);
m.subscribe(subscriber);
source.onNext(1);
source.onNext(2);
scheduler.advanceTimeBy(100, TimeUnit.MILLISECONDS);
scheduler.advanceTimeBy(100, TimeUnit.MILLISECONDS);
Reported by PMD.
src/test/java/io/reactivex/rxjava3/internal/jdk8/CompletableFromCompletionStageTest.java
19 issues
Line: 28
public class CompletableFromCompletionStageTest extends RxJavaTest {
@Test
public void syncSuccess() {
Completable.fromCompletionStage(CompletableFuture.completedFuture(1))
.test()
.assertResult();
}
Reported by PMD.
Line: 29
@Test
public void syncSuccess() {
Completable.fromCompletionStage(CompletableFuture.completedFuture(1))
.test()
.assertResult();
}
@Test
Reported by PMD.
Line: 29
@Test
public void syncSuccess() {
Completable.fromCompletionStage(CompletableFuture.completedFuture(1))
.test()
.assertResult();
}
@Test
Reported by PMD.
Line: 35
}
@Test
public void syncSuccessNull() {
Completable.fromCompletionStage(CompletableFuture.completedFuture(null))
.test()
.assertResult();
}
Reported by PMD.
Line: 36
@Test
public void syncSuccessNull() {
Completable.fromCompletionStage(CompletableFuture.completedFuture(null))
.test()
.assertResult();
}
@Test
Reported by PMD.
Line: 36
@Test
public void syncSuccessNull() {
Completable.fromCompletionStage(CompletableFuture.completedFuture(null))
.test()
.assertResult();
}
@Test
Reported by PMD.
Line: 42
}
@Test
public void syncFailure() {
CompletableFuture<Integer> cf = new CompletableFuture<>();
cf.completeExceptionally(new TestException());
Completable.fromCompletionStage(cf)
.test()
Reported by PMD.
Line: 46
CompletableFuture<Integer> cf = new CompletableFuture<>();
cf.completeExceptionally(new TestException());
Completable.fromCompletionStage(cf)
.test()
.assertFailure(TestException.class);
}
@Test
Reported by PMD.
Line: 46
CompletableFuture<Integer> cf = new CompletableFuture<>();
cf.completeExceptionally(new TestException());
Completable.fromCompletionStage(cf)
.test()
.assertFailure(TestException.class);
}
@Test
Reported by PMD.
Line: 52
}
@Test
public void syncNull() {
Completable.fromCompletionStage(CompletableFuture.<Integer>completedFuture(null))
.test()
.assertResult();
}
Reported by PMD.
src/main/java/io/reactivex/rxjava3/internal/operators/parallel/ParallelFilter.java
19 issues
Line: 42
}
@Override
public void subscribe(Subscriber<? super T>[] subscribers) {
subscribers = RxJavaPlugins.onSubscribe(this, subscribers);
if (!validate(subscribers)) {
return;
}
Reported by PMD.
Line: 32
*/
public final class ParallelFilter<T> extends ParallelFlowable<T> {
final ParallelFlowable<T> source;
final Predicate<? super T> predicate;
public ParallelFilter(ParallelFlowable<T> source, Predicate<? super T> predicate) {
this.source = source;
Reported by PMD.
Line: 34
final ParallelFlowable<T> source;
final Predicate<? super T> predicate;
public ParallelFilter(ParallelFlowable<T> source, Predicate<? super T> predicate) {
this.source = source;
this.predicate = predicate;
}
Reported by PMD.
Line: 71
}
abstract static class BaseFilterSubscriber<T> implements ConditionalSubscriber<T>, Subscription {
final Predicate<? super T> predicate;
Subscription upstream;
boolean done;
Reported by PMD.
Line: 73
abstract static class BaseFilterSubscriber<T> implements ConditionalSubscriber<T>, Subscription {
final Predicate<? super T> predicate;
Subscription upstream;
boolean done;
BaseFilterSubscriber(Predicate<? super T> predicate) {
this.predicate = predicate;
Reported by PMD.
Line: 75
Subscription upstream;
boolean done;
BaseFilterSubscriber(Predicate<? super T> predicate) {
this.predicate = predicate;
}
Reported by PMD.
Line: 101
static final class ParallelFilterSubscriber<T> extends BaseFilterSubscriber<T> {
final Subscriber<? super T> downstream;
ParallelFilterSubscriber(Subscriber<? super T> actual, Predicate<? super T> predicate) {
super(predicate);
this.downstream = actual;
}
Reported by PMD.
Line: 124
try {
b = predicate.test(t);
} catch (Throwable ex) {
Exceptions.throwIfFatal(ex);
cancel();
onError(ex);
return false;
}
Reported by PMD.
Line: 160
static final class ParallelFilterConditionalSubscriber<T> extends BaseFilterSubscriber<T> {
final ConditionalSubscriber<? super T> downstream;
ParallelFilterConditionalSubscriber(ConditionalSubscriber<? super T> actual, Predicate<? super T> predicate) {
super(predicate);
this.downstream = actual;
}
Reported by PMD.
Line: 183
try {
b = predicate.test(t);
} catch (Throwable ex) {
Exceptions.throwIfFatal(ex);
cancel();
onError(ex);
return false;
}
Reported by PMD.
src/main/java/io/reactivex/rxjava3/internal/operators/observable/BlockingObservableNext.java
19 issues
Line: 34
*/
public final class BlockingObservableNext<T> implements Iterable<T> {
final ObservableSource<T> source;
public BlockingObservableNext(ObservableSource<T> source) {
this.source = source;
}
Reported by PMD.
Line: 49
// test needs to access the observer.waiting flag
static final class NextIterator<T> implements Iterator<T> {
private final NextObserver<T> observer;
private final ObservableSource<T> items;
private T next;
private boolean hasNext = true;
private boolean isNextConsumed = true;
private Throwable error;
Reported by PMD.
Line: 50
static final class NextIterator<T> implements Iterator<T> {
private final NextObserver<T> observer;
private final ObservableSource<T> items;
private T next;
private boolean hasNext = true;
private boolean isNextConsumed = true;
private Throwable error;
private boolean started;
Reported by PMD.
Line: 51
private final NextObserver<T> observer;
private final ObservableSource<T> items;
private T next;
private boolean hasNext = true;
private boolean isNextConsumed = true;
private Throwable error;
private boolean started;
Reported by PMD.
Line: 51
private final NextObserver<T> observer;
private final ObservableSource<T> items;
private T next;
private boolean hasNext = true;
private boolean isNextConsumed = true;
private Throwable error;
private boolean started;
Reported by PMD.
Line: 52
private final NextObserver<T> observer;
private final ObservableSource<T> items;
private T next;
private boolean hasNext = true;
private boolean isNextConsumed = true;
private Throwable error;
private boolean started;
NextIterator(ObservableSource<T> items, NextObserver<T> observer) {
Reported by PMD.
Line: 52
private final NextObserver<T> observer;
private final ObservableSource<T> items;
private T next;
private boolean hasNext = true;
private boolean isNextConsumed = true;
private Throwable error;
private boolean started;
NextIterator(ObservableSource<T> items, NextObserver<T> observer) {
Reported by PMD.
Line: 53
private final ObservableSource<T> items;
private T next;
private boolean hasNext = true;
private boolean isNextConsumed = true;
private Throwable error;
private boolean started;
NextIterator(ObservableSource<T> items, NextObserver<T> observer) {
this.items = items;
Reported by PMD.
Line: 54
private T next;
private boolean hasNext = true;
private boolean isNextConsumed = true;
private Throwable error;
private boolean started;
NextIterator(ObservableSource<T> items, NextObserver<T> observer) {
this.items = items;
this.observer = observer;
Reported by PMD.
Line: 55
private boolean hasNext = true;
private boolean isNextConsumed = true;
private Throwable error;
private boolean started;
NextIterator(ObservableSource<T> items, NextObserver<T> observer) {
this.items = items;
this.observer = observer;
}
Reported by PMD.
src/main/java/io/reactivex/rxjava3/internal/operators/completable/CompletablePeek.java
19 issues
Line: 82
}
@Override
public void onError(Throwable e) {
if (upstream == DisposableHelper.DISPOSED) {
RxJavaPlugins.onError(e);
return;
}
try {
Reported by PMD.
Line: 25
public final class CompletablePeek extends Completable {
final CompletableSource source;
final Consumer<? super Disposable> onSubscribe;
final Consumer<? super Throwable> onError;
final Action onComplete;
final Action onTerminate;
final Action onAfterTerminate;
Reported by PMD.
Line: 26
public final class CompletablePeek extends Completable {
final CompletableSource source;
final Consumer<? super Disposable> onSubscribe;
final Consumer<? super Throwable> onError;
final Action onComplete;
final Action onTerminate;
final Action onAfterTerminate;
final Action onDispose;
Reported by PMD.
Line: 27
final CompletableSource source;
final Consumer<? super Disposable> onSubscribe;
final Consumer<? super Throwable> onError;
final Action onComplete;
final Action onTerminate;
final Action onAfterTerminate;
final Action onDispose;
Reported by PMD.
Line: 28
final CompletableSource source;
final Consumer<? super Disposable> onSubscribe;
final Consumer<? super Throwable> onError;
final Action onComplete;
final Action onTerminate;
final Action onAfterTerminate;
final Action onDispose;
public CompletablePeek(CompletableSource source, Consumer<? super Disposable> onSubscribe,
Reported by PMD.
Line: 29
final Consumer<? super Disposable> onSubscribe;
final Consumer<? super Throwable> onError;
final Action onComplete;
final Action onTerminate;
final Action onAfterTerminate;
final Action onDispose;
public CompletablePeek(CompletableSource source, Consumer<? super Disposable> onSubscribe,
Consumer<? super Throwable> onError,
Reported by PMD.
Line: 30
final Consumer<? super Throwable> onError;
final Action onComplete;
final Action onTerminate;
final Action onAfterTerminate;
final Action onDispose;
public CompletablePeek(CompletableSource source, Consumer<? super Disposable> onSubscribe,
Consumer<? super Throwable> onError,
Action onComplete,
Reported by PMD.
Line: 31
final Action onComplete;
final Action onTerminate;
final Action onAfterTerminate;
final Action onDispose;
public CompletablePeek(CompletableSource source, Consumer<? super Disposable> onSubscribe,
Consumer<? super Throwable> onError,
Action onComplete,
Action onTerminate,
Reported by PMD.
Line: 56
final class CompletableObserverImplementation implements CompletableObserver, Disposable {
final CompletableObserver downstream;
Disposable upstream;
CompletableObserverImplementation(CompletableObserver downstream) {
this.downstream = downstream;
Reported by PMD.
Line: 58
final CompletableObserver downstream;
Disposable upstream;
CompletableObserverImplementation(CompletableObserver downstream) {
this.downstream = downstream;
}
Reported by PMD.