Package io.reactivex.rxjava3.internal.operators.parallel

Class ParallelFilter.BaseFilterSubscriber<T>

java.lang.Object

io.reactivex.rxjava3.internal.operators.parallel.ParallelFilter.BaseFilterSubscriber<T>

All Implemented Interfaces:

FlowableSubscriber<T>, ConditionalSubscriber<T>, org.reactivestreams.Subscriber<T>, org.reactivestreams.Subscription

Direct Known Subclasses:

ParallelFilter.ParallelFilterConditionalSubscriber, ParallelFilter.ParallelFilterSubscriber

Enclosing class:

ParallelFilter<T>

abstract static class ParallelFilter.BaseFilterSubscriber<T>
extends Object
implements ConditionalSubscriber<T>, org.reactivestreams.Subscription

Field Summary

Fields

Modifier and Type	Field	Description
(package private) boolean	done
(package private) final Predicate<? super T>	predicate
(package private) org.reactivestreams.Subscription	upstream

Constructor Summary

Constructors

Constructor	Description
BaseFilterSubscriber(Predicate<? super T> predicate)

Method Summary

Modifier and Type	Method	Description
final void	cancel()
final void	onNext(T t)
final void	request(long n)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.reactivex.rxjava3.operators.ConditionalSubscriber

tryOnNext

Methods inherited from interface io.reactivex.rxjava3.core.FlowableSubscriber

onSubscribe

Methods inherited from interface org.reactivestreams.Subscriber

onComplete, onError

Field Details

predicate

final Predicate<? super T> predicate

upstream

org.reactivestreams.Subscription upstream

done

boolean done

Constructor Details

BaseFilterSubscriber

BaseFilterSubscriber(Predicate<? super T> predicate)

Method Details

request

public final void request(long n)

Specified by:

request in interface org.reactivestreams.Subscription

cancel

public final void cancel()

Specified by:

cancel in interface org.reactivestreams.Subscription

onNext

public final void onNext(T t)

Specified by:

onNext in interface org.reactivestreams.Subscriber<T>