Class ParallelFilterTry.ParallelFilterSubscriber<T>

java.lang.Object

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

io.reactivex.rxjava3.internal.operators.parallel.ParallelFilterTry.ParallelFilterSubscriber<T>

All Implemented Interfaces:

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

Enclosing class:

ParallelFilterTry<T>

static final class ParallelFilterTry.ParallelFilterSubscriber<T>
extends ParallelFilterTry.BaseFilterSubscriber<T>

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final org.reactivestreams.Subscriber<? super T>	downstream

Fields inherited from class ParallelFilterTry.BaseFilterSubscriber

done, errorHandler, predicate, upstream

Constructor Summary

Constructors

Constructor	Description
ParallelFilterSubscriber(org.reactivestreams.Subscriber<? super T> actual, Predicate<? super T> predicate, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler)

Method Summary

Modifier and Type	Method	Description
void	onComplete()
void	onError(Throwable t)
void	onSubscribe(org.reactivestreams.Subscription s)	Implementors of this method should make sure everything that needs to be visible in Subscriber.onNext(Object) is established before calling Subscription.request(long).
boolean	tryOnNext(T t)	Conditionally takes the value.

Methods inherited from class ParallelFilterTry.BaseFilterSubscriber

cancel, onNext, request

Methods inherited from class Object

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

Field Details

downstream

final org.reactivestreams.Subscriber<? super T> downstream

Constructor Details

ParallelFilterSubscriber

ParallelFilterSubscriber(org.reactivestreams.Subscriber<? super T> actual,
 Predicate<? super T> predicate,
 BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler)

Method Details

onSubscribe

public void onSubscribe(org.reactivestreams.Subscription s)

Description copied from interface: FlowableSubscriber

Implementors of this method should make sure everything that needs to be visible in Subscriber.onNext(Object) is established before calling Subscription.request(long). In practice this means no initialization should happen after the request() call and additional behavior is thread safe in respect to onNext.

tryOnNext

public boolean tryOnNext(T t)

Description copied from interface: ConditionalSubscriber

Conditionally takes the value.

Parameters:

t - the value to deliver

Returns:

true if the value has been accepted, false if the value has been rejected and the next value can be sent immediately

onError

public void onError(Throwable t)

onComplete

public void onComplete()