The following issues were found
src/main/java/io/reactivex/rxjava3/internal/operators/flowable/FlowableSubscribeOn.java
18 issues
Line: 32
*/
public final class FlowableSubscribeOn<T> extends AbstractFlowableWithUpstream<T , T> {
final Scheduler scheduler;
final boolean nonScheduledRequests;
public FlowableSubscribeOn(Flowable<T> source, Scheduler scheduler, boolean nonScheduledRequests) {
super(source);
Reported by PMD.
Line: 34
final Scheduler scheduler;
final boolean nonScheduledRequests;
public FlowableSubscribeOn(Flowable<T> source, Scheduler scheduler, boolean nonScheduledRequests) {
super(source);
this.scheduler = scheduler;
this.nonScheduledRequests = nonScheduledRequests;
Reported by PMD.
Line: 48
final SubscribeOnSubscriber<T> sos = new SubscribeOnSubscriber<>(s, w, source, nonScheduledRequests);
s.onSubscribe(sos);
w.schedule(sos);
}
static final class SubscribeOnSubscriber<T> extends AtomicReference<Thread>
implements FlowableSubscriber<T>, Subscription, Runnable {
Reported by PMD.
Line: 56
private static final long serialVersionUID = 8094547886072529208L;
final Subscriber<? super T> downstream;
final Scheduler.Worker worker;
final AtomicReference<Subscription> upstream;
Reported by PMD.
Line: 58
final Subscriber<? super T> downstream;
final Scheduler.Worker worker;
final AtomicReference<Subscription> upstream;
final AtomicLong requested;
Reported by PMD.
Line: 60
final Scheduler.Worker worker;
final AtomicReference<Subscription> upstream;
final AtomicLong requested;
final boolean nonScheduledRequests;
Reported by PMD.
Line: 62
final AtomicReference<Subscription> upstream;
final AtomicLong requested;
final boolean nonScheduledRequests;
Publisher<T> source;
Reported by PMD.
Line: 64
final AtomicLong requested;
final boolean nonScheduledRequests;
Publisher<T> source;
SubscribeOnSubscriber(Subscriber<? super T> actual, Scheduler.Worker worker, Publisher<T> source, boolean requestOn) {
this.downstream = actual;
Reported by PMD.
Line: 66
final boolean nonScheduledRequests;
Publisher<T> source;
SubscribeOnSubscriber(Subscriber<? super T> actual, Scheduler.Worker worker, Publisher<T> source, boolean requestOn) {
this.downstream = actual;
this.worker = worker;
this.source = source;
Reported by PMD.
Line: 81
public void run() {
lazySet(Thread.currentThread());
Publisher<T> src = source;
source = null;
src.subscribe(this);
}
@Override
public void onSubscribe(Subscription s) {
Reported by PMD.
src/main/java/io/reactivex/rxjava3/internal/schedulers/SchedulerWhen.java
18 issues
Line: 103
* @since 2.1
*/
public class SchedulerWhen extends Scheduler implements Disposable {
private final Scheduler actualScheduler;
private final FlowableProcessor<Flowable<Completable>> workerProcessor;
private Disposable disposable;
public SchedulerWhen(Function<Flowable<Flowable<Completable>>, Completable> combine, Scheduler actualScheduler) {
this.actualScheduler = actualScheduler;
Reported by PMD.
Line: 104
*/
public class SchedulerWhen extends Scheduler implements Disposable {
private final Scheduler actualScheduler;
private final FlowableProcessor<Flowable<Completable>> workerProcessor;
private Disposable disposable;
public SchedulerWhen(Function<Flowable<Flowable<Completable>>, Completable> combine, Scheduler actualScheduler) {
this.actualScheduler = actualScheduler;
// workers are converted into completables and put in this queue.
Reported by PMD.
Line: 105
public class SchedulerWhen extends Scheduler implements Disposable {
private final Scheduler actualScheduler;
private final FlowableProcessor<Flowable<Completable>> workerProcessor;
private Disposable disposable;
public SchedulerWhen(Function<Flowable<Flowable<Completable>>, Completable> combine, Scheduler actualScheduler) {
this.actualScheduler = actualScheduler;
// workers are converted into completables and put in this queue.
this.workerProcessor = UnicastProcessor.<Flowable<Completable>>create().toSerialized();
Reported by PMD.
Line: 115
// workers are processed.
try {
disposable = combine.apply(workerProcessor).subscribe();
} catch (Throwable e) {
throw ExceptionHelper.wrapOrThrow(e);
}
}
@Override
Reported by PMD.
Line: 136
final Worker actualWorker = actualScheduler.createWorker();
// a queue for the actions submitted while worker is waiting to get to
// the subscribe to off the workerQueue.
final FlowableProcessor<ScheduledAction> actionProcessor = UnicastProcessor.<ScheduledAction>create().toSerialized();
// convert the work of scheduling all the actions into a completable
Flowable<Completable> actions = actionProcessor.map(new CreateWorkerFunction(actualWorker));
// a worker that queues the action to the actionQueue subject.
Worker worker = new QueueWorker(actionProcessor, actualWorker);
Reported by PMD.
Line: 136
final Worker actualWorker = actualScheduler.createWorker();
// a queue for the actions submitted while worker is waiting to get to
// the subscribe to off the workerQueue.
final FlowableProcessor<ScheduledAction> actionProcessor = UnicastProcessor.<ScheduledAction>create().toSerialized();
// convert the work of scheduling all the actions into a completable
Flowable<Completable> actions = actionProcessor.map(new CreateWorkerFunction(actualWorker));
// a worker that queues the action to the actionQueue subject.
Worker worker = new QueueWorker(actionProcessor, actualWorker);
Reported by PMD.
Line: 189
@Override
public boolean isDisposed() {
return get().isDisposed();
}
@Override
public void dispose() {
getAndSet(DISPOSED).dispose();
Reported by PMD.
Line: 194
@Override
public void dispose() {
getAndSet(DISPOSED).dispose();
}
}
@SuppressWarnings("serial")
static class ImmediateAction extends ScheduledAction {
Reported by PMD.
Line: 231
}
static class OnCompletedAction implements Runnable {
final CompletableObserver actionCompletable;
final Runnable action;
OnCompletedAction(Runnable action, CompletableObserver actionCompletable) {
this.action = action;
this.actionCompletable = actionCompletable;
Reported by PMD.
Line: 232
static class OnCompletedAction implements Runnable {
final CompletableObserver actionCompletable;
final Runnable action;
OnCompletedAction(Runnable action, CompletableObserver actionCompletable) {
this.action = action;
this.actionCompletable = actionCompletable;
}
Reported by PMD.
src/main/java/io/reactivex/rxjava3/internal/operators/flowable/FlowableBufferExactBoundary.java
18 issues
Line: 33
public final class FlowableBufferExactBoundary<T, U extends Collection<? super T>, B>
extends AbstractFlowableWithUpstream<T, U> {
final Publisher<B> boundary;
final Supplier<U> bufferSupplier;
public FlowableBufferExactBoundary(Flowable<T> source, Publisher<B> boundary, Supplier<U> bufferSupplier) {
super(source);
this.boundary = boundary;
Reported by PMD.
Line: 34
public final class FlowableBufferExactBoundary<T, U extends Collection<? super T>, B>
extends AbstractFlowableWithUpstream<T, U> {
final Publisher<B> boundary;
final Supplier<U> bufferSupplier;
public FlowableBufferExactBoundary(Flowable<T> source, Publisher<B> boundary, Supplier<U> bufferSupplier) {
super(source);
this.boundary = boundary;
this.bufferSupplier = bufferSupplier;
Reported by PMD.
Line: 50
static final class BufferExactBoundarySubscriber<T, U extends Collection<? super T>, B>
extends QueueDrainSubscriber<T, U, U> implements FlowableSubscriber<T>, Subscription, Disposable {
final Supplier<U> bufferSupplier;
final Publisher<B> boundary;
Subscription upstream;
Disposable other;
Reported by PMD.
Line: 51
extends QueueDrainSubscriber<T, U, U> implements FlowableSubscriber<T>, Subscription, Disposable {
final Supplier<U> bufferSupplier;
final Publisher<B> boundary;
Subscription upstream;
Disposable other;
Reported by PMD.
Line: 53
final Supplier<U> bufferSupplier;
final Publisher<B> boundary;
Subscription upstream;
Disposable other;
U buffer;
Reported by PMD.
Line: 55
Subscription upstream;
Disposable other;
U buffer;
BufferExactBoundarySubscriber(Subscriber<? super U> actual, Supplier<U> bufferSupplier,
Publisher<B> boundary) {
Reported by PMD.
Line: 57
Disposable other;
U buffer;
BufferExactBoundarySubscriber(Subscriber<? super U> actual, Supplier<U> bufferSupplier,
Publisher<B> boundary) {
super(actual, new MpscLinkedQueue<>());
this.bufferSupplier = bufferSupplier;
Reported by PMD.
Line: 77
try {
b = Objects.requireNonNull(bufferSupplier.get(), "The buffer supplied is null");
} catch (Throwable e) {
Exceptions.throwIfFatal(e);
cancelled = true;
s.cancel();
EmptySubscription.error(e, downstream);
return;
Reported by PMD.
Line: 106
if (b == null) {
return;
}
b.add(t);
}
}
@Override
public void onError(Throwable t) {
Reported by PMD.
Line: 124
if (b == null) {
return;
}
buffer = null;
}
queue.offer(b);
done = true;
if (enter()) {
QueueDrainHelper.drainMaxLoop(queue, downstream, false, this, this);
Reported by PMD.
src/main/java/io/reactivex/rxjava3/internal/operators/maybe/MaybeFlatMapBiSelector.java
18 issues
Line: 35
*/
public final class MaybeFlatMapBiSelector<T, U, R> extends AbstractMaybeWithUpstream<T, R> {
final Function<? super T, ? extends MaybeSource<? extends U>> mapper;
final BiFunction<? super T, ? super U, ? extends R> resultSelector;
public MaybeFlatMapBiSelector(MaybeSource<T> source,
Function<? super T, ? extends MaybeSource<? extends U>> mapper,
Reported by PMD.
Line: 37
final Function<? super T, ? extends MaybeSource<? extends U>> mapper;
final BiFunction<? super T, ? super U, ? extends R> resultSelector;
public MaybeFlatMapBiSelector(MaybeSource<T> source,
Function<? super T, ? extends MaybeSource<? extends U>> mapper,
BiFunction<? super T, ? super U, ? extends R> resultSelector) {
super(source);
Reported by PMD.
Line: 55
static final class FlatMapBiMainObserver<T, U, R>
implements MaybeObserver<T>, Disposable {
final Function<? super T, ? extends MaybeSource<? extends U>> mapper;
final InnerObserver<T, U, R> inner;
FlatMapBiMainObserver(MaybeObserver<? super R> actual,
Function<? super T, ? extends MaybeSource<? extends U>> mapper,
Reported by PMD.
Line: 57
final Function<? super T, ? extends MaybeSource<? extends U>> mapper;
final InnerObserver<T, U, R> inner;
FlatMapBiMainObserver(MaybeObserver<? super R> actual,
Function<? super T, ? extends MaybeSource<? extends U>> mapper,
BiFunction<? super T, ? super U, ? extends R> resultSelector) {
this.inner = new InnerObserver<>(actual, resultSelector);
Reported by PMD.
Line: 79
@Override
public void onSubscribe(Disposable d) {
if (DisposableHelper.setOnce(inner, d)) {
inner.downstream.onSubscribe(this);
}
}
@Override
public void onSuccess(T value) {
Reported by PMD.
Line: 89
try {
next = Objects.requireNonNull(mapper.apply(value), "The mapper returned a null MaybeSource");
} catch (Throwable ex) {
Exceptions.throwIfFatal(ex);
inner.downstream.onError(ex);
return;
}
Reported by PMD.
Line: 91
next = Objects.requireNonNull(mapper.apply(value), "The mapper returned a null MaybeSource");
} catch (Throwable ex) {
Exceptions.throwIfFatal(ex);
inner.downstream.onError(ex);
return;
}
if (DisposableHelper.replace(inner, null)) {
inner.value = value;
Reported by PMD.
Line: 103
@Override
public void onError(Throwable e) {
inner.downstream.onError(e);
}
@Override
public void onComplete() {
inner.downstream.onComplete();
Reported by PMD.
Line: 108
@Override
public void onComplete() {
inner.downstream.onComplete();
}
static final class InnerObserver<T, U, R>
extends AtomicReference<Disposable>
implements MaybeObserver<U> {
Reported by PMD.
Line: 117
private static final long serialVersionUID = -2897979525538174559L;
final MaybeObserver<? super R> downstream;
final BiFunction<? super T, ? super U, ? extends R> resultSelector;
T value;
Reported by PMD.
src/main/java/io/reactivex/rxjava3/internal/operators/flowable/FlowableZipIterable.java
17 issues
Line: 28
import io.reactivex.rxjava3.plugins.RxJavaPlugins;
public final class FlowableZipIterable<T, U, V> extends AbstractFlowableWithUpstream<T, V> {
final Iterable<U> other;
final BiFunction<? super T, ? super U, ? extends V> zipper;
public FlowableZipIterable(
Flowable<T> source,
Iterable<U> other, BiFunction<? super T, ? super U, ? extends V> zipper) {
Reported by PMD.
Line: 29
public final class FlowableZipIterable<T, U, V> extends AbstractFlowableWithUpstream<T, V> {
final Iterable<U> other;
final BiFunction<? super T, ? super U, ? extends V> zipper;
public FlowableZipIterable(
Flowable<T> source,
Iterable<U> other, BiFunction<? super T, ? super U, ? extends V> zipper) {
super(source);
Reported by PMD.
Line: 45
try {
it = Objects.requireNonNull(other.iterator(), "The iterator returned by other is null");
} catch (Throwable e) {
Exceptions.throwIfFatal(e);
EmptySubscription.error(e, t);
return;
}
Reported by PMD.
Line: 55
try {
b = it.hasNext();
} catch (Throwable e) {
Exceptions.throwIfFatal(e);
EmptySubscription.error(e, t);
return;
}
Reported by PMD.
Line: 70
}
static final class ZipIterableSubscriber<T, U, V> implements FlowableSubscriber<T>, Subscription {
final Subscriber<? super V> downstream;
final Iterator<U> iterator;
final BiFunction<? super T, ? super U, ? extends V> zipper;
Subscription upstream;
Reported by PMD.
Line: 71
static final class ZipIterableSubscriber<T, U, V> implements FlowableSubscriber<T>, Subscription {
final Subscriber<? super V> downstream;
final Iterator<U> iterator;
final BiFunction<? super T, ? super U, ? extends V> zipper;
Subscription upstream;
boolean done;
Reported by PMD.
Line: 72
static final class ZipIterableSubscriber<T, U, V> implements FlowableSubscriber<T>, Subscription {
final Subscriber<? super V> downstream;
final Iterator<U> iterator;
final BiFunction<? super T, ? super U, ? extends V> zipper;
Subscription upstream;
boolean done;
Reported by PMD.
Line: 74
final Iterator<U> iterator;
final BiFunction<? super T, ? super U, ? extends V> zipper;
Subscription upstream;
boolean done;
ZipIterableSubscriber(Subscriber<? super V> actual, Iterator<U> iterator,
BiFunction<? super T, ? super U, ? extends V> zipper) {
Reported by PMD.
Line: 76
Subscription upstream;
boolean done;
ZipIterableSubscriber(Subscriber<? super V> actual, Iterator<U> iterator,
BiFunction<? super T, ? super U, ? extends V> zipper) {
this.downstream = actual;
this.iterator = iterator;
Reported by PMD.
Line: 103
try {
u = Objects.requireNonNull(iterator.next(), "The iterator returned a null value");
} catch (Throwable e) {
fail(e);
return;
}
V v;
Reported by PMD.
src/main/java/io/reactivex/rxjava3/internal/operators/maybe/MaybeFlatMapNotification.java
17 issues
Line: 33
*/
public final class MaybeFlatMapNotification<T, R> extends AbstractMaybeWithUpstream<T, R> {
final Function<? super T, ? extends MaybeSource<? extends R>> onSuccessMapper;
final Function<? super Throwable, ? extends MaybeSource<? extends R>> onErrorMapper;
final Supplier<? extends MaybeSource<? extends R>> onCompleteSupplier;
Reported by PMD.
Line: 35
final Function<? super T, ? extends MaybeSource<? extends R>> onSuccessMapper;
final Function<? super Throwable, ? extends MaybeSource<? extends R>> onErrorMapper;
final Supplier<? extends MaybeSource<? extends R>> onCompleteSupplier;
public MaybeFlatMapNotification(MaybeSource<T> source,
Function<? super T, ? extends MaybeSource<? extends R>> onSuccessMapper,
Reported by PMD.
Line: 37
final Function<? super Throwable, ? extends MaybeSource<? extends R>> onErrorMapper;
final Supplier<? extends MaybeSource<? extends R>> onCompleteSupplier;
public MaybeFlatMapNotification(MaybeSource<T> source,
Function<? super T, ? extends MaybeSource<? extends R>> onSuccessMapper,
Function<? super Throwable, ? extends MaybeSource<? extends R>> onErrorMapper,
Supplier<? extends MaybeSource<? extends R>> onCompleteSupplier) {
Reported by PMD.
Line: 60
private static final long serialVersionUID = 4375739915521278546L;
final MaybeObserver<? super R> downstream;
final Function<? super T, ? extends MaybeSource<? extends R>> onSuccessMapper;
final Function<? super Throwable, ? extends MaybeSource<? extends R>> onErrorMapper;
Reported by PMD.
Line: 62
final MaybeObserver<? super R> downstream;
final Function<? super T, ? extends MaybeSource<? extends R>> onSuccessMapper;
final Function<? super Throwable, ? extends MaybeSource<? extends R>> onErrorMapper;
final Supplier<? extends MaybeSource<? extends R>> onCompleteSupplier;
Reported by PMD.
Line: 64
final Function<? super T, ? extends MaybeSource<? extends R>> onSuccessMapper;
final Function<? super Throwable, ? extends MaybeSource<? extends R>> onErrorMapper;
final Supplier<? extends MaybeSource<? extends R>> onCompleteSupplier;
Disposable upstream;
Reported by PMD.
Line: 66
final Function<? super Throwable, ? extends MaybeSource<? extends R>> onErrorMapper;
final Supplier<? extends MaybeSource<? extends R>> onCompleteSupplier;
Disposable upstream;
FlatMapMaybeObserver(MaybeObserver<? super R> actual,
Function<? super T, ? extends MaybeSource<? extends R>> onSuccessMapper,
Reported by PMD.
Line: 68
final Supplier<? extends MaybeSource<? extends R>> onCompleteSupplier;
Disposable upstream;
FlatMapMaybeObserver(MaybeObserver<? super R> actual,
Function<? super T, ? extends MaybeSource<? extends R>> onSuccessMapper,
Function<? super Throwable, ? extends MaybeSource<? extends R>> onErrorMapper,
Supplier<? extends MaybeSource<? extends R>> onCompleteSupplier) {
Reported by PMD.
Line: 106
try {
source = Objects.requireNonNull(onSuccessMapper.apply(value), "The onSuccessMapper returned a null MaybeSource");
} catch (Throwable ex) {
Exceptions.throwIfFatal(ex);
downstream.onError(ex);
return;
}
Reported by PMD.
Line: 123
try {
source = Objects.requireNonNull(onErrorMapper.apply(e), "The onErrorMapper returned a null MaybeSource");
} catch (Throwable ex) {
Exceptions.throwIfFatal(ex);
downstream.onError(new CompositeException(e, ex));
return;
}
Reported by PMD.
src/main/java/io/reactivex/rxjava3/internal/operators/flowable/FlowableSampleTimed.java
17 issues
Line: 29
import io.reactivex.rxjava3.subscribers.SerializedSubscriber;
public final class FlowableSampleTimed<T> extends AbstractFlowableWithUpstream<T, T> {
final long period;
final TimeUnit unit;
final Scheduler scheduler;
final boolean emitLast;
Reported by PMD.
Line: 30
public final class FlowableSampleTimed<T> extends AbstractFlowableWithUpstream<T, T> {
final long period;
final TimeUnit unit;
final Scheduler scheduler;
final boolean emitLast;
public FlowableSampleTimed(Flowable<T> source, long period, TimeUnit unit, Scheduler scheduler, boolean emitLast) {
Reported by PMD.
Line: 31
public final class FlowableSampleTimed<T> extends AbstractFlowableWithUpstream<T, T> {
final long period;
final TimeUnit unit;
final Scheduler scheduler;
final boolean emitLast;
public FlowableSampleTimed(Flowable<T> source, long period, TimeUnit unit, Scheduler scheduler, boolean emitLast) {
super(source);
Reported by PMD.
Line: 33
final TimeUnit unit;
final Scheduler scheduler;
final boolean emitLast;
public FlowableSampleTimed(Flowable<T> source, long period, TimeUnit unit, Scheduler scheduler, boolean emitLast) {
super(source);
this.period = period;
this.unit = unit;
Reported by PMD.
Line: 57
private static final long serialVersionUID = -3517602651313910099L;
final Subscriber<? super T> downstream;
final long period;
final TimeUnit unit;
final Scheduler scheduler;
final AtomicLong requested = new AtomicLong();
Reported by PMD.
Line: 58
private static final long serialVersionUID = -3517602651313910099L;
final Subscriber<? super T> downstream;
final long period;
final TimeUnit unit;
final Scheduler scheduler;
final AtomicLong requested = new AtomicLong();
Reported by PMD.
Line: 59
final Subscriber<? super T> downstream;
final long period;
final TimeUnit unit;
final Scheduler scheduler;
final AtomicLong requested = new AtomicLong();
final SequentialDisposable timer = new SequentialDisposable();
Reported by PMD.
Line: 60
final Subscriber<? super T> downstream;
final long period;
final TimeUnit unit;
final Scheduler scheduler;
final AtomicLong requested = new AtomicLong();
final SequentialDisposable timer = new SequentialDisposable();
Reported by PMD.
Line: 62
final TimeUnit unit;
final Scheduler scheduler;
final AtomicLong requested = new AtomicLong();
final SequentialDisposable timer = new SequentialDisposable();
Subscription upstream;
Reported by PMD.
Line: 64
final AtomicLong requested = new AtomicLong();
final SequentialDisposable timer = new SequentialDisposable();
Subscription upstream;
SampleTimedSubscriber(Subscriber<? super T> actual, long period, TimeUnit unit, Scheduler scheduler) {
this.downstream = actual;
Reported by PMD.
src/main/java/io/reactivex/rxjava3/internal/operators/observable/ObservableBufferExactBoundary.java
17 issues
Line: 31
public final class ObservableBufferExactBoundary<T, U extends Collection<? super T>, B>
extends AbstractObservableWithUpstream<T, U> {
final ObservableSource<B> boundary;
final Supplier<U> bufferSupplier;
public ObservableBufferExactBoundary(ObservableSource<T> source, ObservableSource<B> boundary, Supplier<U> bufferSupplier) {
super(source);
this.boundary = boundary;
Reported by PMD.
Line: 32
public final class ObservableBufferExactBoundary<T, U extends Collection<? super T>, B>
extends AbstractObservableWithUpstream<T, U> {
final ObservableSource<B> boundary;
final Supplier<U> bufferSupplier;
public ObservableBufferExactBoundary(ObservableSource<T> source, ObservableSource<B> boundary, Supplier<U> bufferSupplier) {
super(source);
this.boundary = boundary;
this.bufferSupplier = bufferSupplier;
Reported by PMD.
Line: 48
static final class BufferExactBoundaryObserver<T, U extends Collection<? super T>, B>
extends QueueDrainObserver<T, U, U> implements Observer<T>, Disposable {
final Supplier<U> bufferSupplier;
final ObservableSource<B> boundary;
Disposable upstream;
Disposable other;
Reported by PMD.
Line: 49
extends QueueDrainObserver<T, U, U> implements Observer<T>, Disposable {
final Supplier<U> bufferSupplier;
final ObservableSource<B> boundary;
Disposable upstream;
Disposable other;
Reported by PMD.
Line: 51
final Supplier<U> bufferSupplier;
final ObservableSource<B> boundary;
Disposable upstream;
Disposable other;
U buffer;
Reported by PMD.
Line: 53
Disposable upstream;
Disposable other;
U buffer;
BufferExactBoundaryObserver(Observer<? super U> actual, Supplier<U> bufferSupplier,
ObservableSource<B> boundary) {
Reported by PMD.
Line: 55
Disposable other;
U buffer;
BufferExactBoundaryObserver(Observer<? super U> actual, Supplier<U> bufferSupplier,
ObservableSource<B> boundary) {
super(actual, new MpscLinkedQueue<>());
this.bufferSupplier = bufferSupplier;
Reported by PMD.
Line: 73
try {
b = Objects.requireNonNull(bufferSupplier.get(), "The buffer supplied is null");
} catch (Throwable e) {
Exceptions.throwIfFatal(e);
cancelled = true;
d.dispose();
EmptyDisposable.error(e, downstream);
return;
Reported by PMD.
Line: 101
if (b == null) {
return;
}
b.add(t);
}
}
@Override
public void onError(Throwable t) {
Reported by PMD.
Line: 119
if (b == null) {
return;
}
buffer = null;
}
queue.offer(b);
done = true;
if (enter()) {
QueueDrainHelper.drainLoop(queue, downstream, false, this, this);
Reported by PMD.
src/main/java/io/reactivex/rxjava3/internal/operators/observable/ObservableDebounce.java
17 issues
Line: 28
import io.reactivex.rxjava3.plugins.RxJavaPlugins;
public final class ObservableDebounce<T, U> extends AbstractObservableWithUpstream<T, T> {
final Function<? super T, ? extends ObservableSource<U>> debounceSelector;
public ObservableDebounce(ObservableSource<T> source, Function<? super T, ? extends ObservableSource<U>> debounceSelector) {
super(source);
this.debounceSelector = debounceSelector;
}
Reported by PMD.
Line: 42
static final class DebounceObserver<T, U>
implements Observer<T>, Disposable {
final Observer<? super T> downstream;
final Function<? super T, ? extends ObservableSource<U>> debounceSelector;
Disposable upstream;
final AtomicReference<Disposable> debouncer = new AtomicReference<>();
Reported by PMD.
Line: 43
static final class DebounceObserver<T, U>
implements Observer<T>, Disposable {
final Observer<? super T> downstream;
final Function<? super T, ? extends ObservableSource<U>> debounceSelector;
Disposable upstream;
final AtomicReference<Disposable> debouncer = new AtomicReference<>();
Reported by PMD.
Line: 45
final Observer<? super T> downstream;
final Function<? super T, ? extends ObservableSource<U>> debounceSelector;
Disposable upstream;
final AtomicReference<Disposable> debouncer = new AtomicReference<>();
volatile long index;
Reported by PMD.
Line: 47
Disposable upstream;
final AtomicReference<Disposable> debouncer = new AtomicReference<>();
volatile long index;
boolean done;
Reported by PMD.
Line: 49
final AtomicReference<Disposable> debouncer = new AtomicReference<>();
volatile long index;
boolean done;
DebounceObserver(Observer<? super T> actual,
Function<? super T, ? extends ObservableSource<U>> debounceSelector) {
Reported by PMD.
Line: 51
volatile long index;
boolean done;
DebounceObserver(Observer<? super T> actual,
Function<? super T, ? extends ObservableSource<U>> debounceSelector) {
this.downstream = actual;
this.debounceSelector = debounceSelector;
Reported by PMD.
Line: 85
try {
p = Objects.requireNonNull(debounceSelector.apply(t), "The ObservableSource supplied is null");
} catch (Throwable e) {
Exceptions.throwIfFatal(e);
dispose();
downstream.onError(e);
return;
}
Reported by PMD.
Line: 116
@SuppressWarnings("unchecked")
DebounceInnerObserver<T, U> dis = (DebounceInnerObserver<T, U>)d;
if (dis != null) {
dis.emit();
}
DisposableHelper.dispose(debouncer);
downstream.onComplete();
}
}
Reported by PMD.
Line: 141
}
static final class DebounceInnerObserver<T, U> extends DisposableObserver<U> {
final DebounceObserver<T, U> parent;
final long index;
final T value;
boolean done;
Reported by PMD.
src/main/java/io/reactivex/rxjava3/internal/jdk8/ObservableFromStream.java
17 issues
Line: 34
*/
public final class ObservableFromStream<T> extends Observable<T> {
final Stream<T> stream;
public ObservableFromStream(Stream<T> stream) {
this.stream = stream;
}
Reported by PMD.
Line: 61
closeSafely(stream);
return;
}
} catch (Throwable ex) {
Exceptions.throwIfFatal(ex);
EmptyDisposable.error(ex, observer);
closeSafely(stream);
return;
}
Reported by PMD.
Line: 76
static void closeSafely(AutoCloseable c) {
try {
c.close();
} catch (Throwable ex) {
Exceptions.throwIfFatal(ex);
RxJavaPlugins.onError(ex);
}
}
Reported by PMD.
Line: 84
static final class StreamDisposable<T> implements QueueDisposable<T> {
final Observer<? super T> downstream;
Iterator<T> iterator;
AutoCloseable closeable;
Reported by PMD.
Line: 86
final Observer<? super T> downstream;
Iterator<T> iterator;
AutoCloseable closeable;
volatile boolean disposed;
Reported by PMD.
Line: 88
Iterator<T> iterator;
AutoCloseable closeable;
volatile boolean disposed;
boolean once;
Reported by PMD.
Line: 90
AutoCloseable closeable;
volatile boolean disposed;
boolean once;
boolean outputFused;
Reported by PMD.
Line: 92
volatile boolean disposed;
boolean once;
boolean outputFused;
StreamDisposable(Observer<? super T> downstream, Iterator<T> iterator, AutoCloseable closeable) {
this.downstream = downstream;
Reported by PMD.
Line: 94
boolean once;
boolean outputFused;
StreamDisposable(Observer<? super T> downstream, Iterator<T> iterator, AutoCloseable closeable) {
this.downstream = downstream;
this.iterator = iterator;
this.closeable = closeable;
Reported by PMD.
Line: 163
@Override
public void clear() {
iterator = null;
AutoCloseable c = closeable;
closeable = null;
if (c != null) {
closeSafely(c);
}
Reported by PMD.