ParallelFilter

java.lang.Object
- io.reactivex.rxjava3.parallel.ParallelFlowable<T>
- - io.reactivex.rxjava3.internal.operators.parallel.ParallelFilter<T>

Type Parameters:

T - the input value type
```
public final class ParallelFilter<T>
extends ParallelFlowable<T>
```
Filters each 'rail' of the source ParallelFlowable with a predicate function.

Nested Class Summary

Nested Classes
Modifier and Type	Class	Description
`(package private) static class`	`ParallelFilter.BaseFilterSubscriber<T>`
`(package private) static class`	`ParallelFilter.ParallelFilterConditionalSubscriber<T>`
`(package private) static class`	`ParallelFilter.ParallelFilterSubscriber<T>`

Field Summary

Fields
Modifier and Type Field Description

(package private) Predicate<? super T> predicate

(package private) ParallelFlowable<T> source

Constructor Summary

Constructors
Constructor Description

ParallelFilter(ParallelFlowable<T> source, Predicate<? super T> predicate)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`int`	`parallelism()`	Returns the number of expected parallel `Subscriber`s.
`void`	`subscribe(org.reactivestreams.Subscriber<? super T>[] subscribers)`	Subscribes an array of `Subscriber`s to this `ParallelFlowable` and triggers the execution chain for all 'rails'.

Methods inherited from class io.reactivex.rxjava3.parallel.ParallelFlowable
collect, collect, compose, concatMap, concatMap, concatMapDelayError, concatMapDelayError, doAfterNext, doAfterTerminated, doOnCancel, doOnComplete, doOnError, doOnNext, doOnNext, doOnNext, doOnRequest, doOnSubscribe, filter, filter, filter, flatMap, flatMap, flatMap, flatMap, flatMapIterable, flatMapIterable, flatMapStream, flatMapStream, from, from, from, fromArray, map, map, map, mapOptional, mapOptional, mapOptional, reduce, reduce, runOn, runOn, sequential, sequential, sequentialDelayError, sequentialDelayError, sorted, sorted, to, toSortedList, toSortedList, validate

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - source
```
final ParallelFlowable<T> source
```
  - predicate
```
final Predicate<? super T> predicate
```
- Constructor Detail
  - ParallelFilter
```
public ParallelFilter(ParallelFlowable<T> source,
                      Predicate<? super T> predicate)
```
- Method Detail
  - subscribe
```
public void subscribe(org.reactivestreams.Subscriber<? super T>[] subscribers)
```
    Description copied from class: ParallelFlowable
    
    Subscribes an array of Subscribers to this ParallelFlowable and triggers the execution chain for all 'rails'.
    
    Backpressure:
    
    The backpressure behavior/expectation is determined by the supplied Subscriber.
    
    Scheduler:
    
    subscribe does not operate by default on a particular Scheduler.
    
    Specified by:
    
    subscribe in class ParallelFlowable<T>
    
    Parameters:
    
    subscribers - the subscribers array to run in parallel, the number of items must be equal to the parallelism level of this ParallelFlowable
    
    See Also:
    
    ParallelFlowable.parallelism()
  - parallelism
```
public int parallelism()
```
    Description copied from class: ParallelFlowable
    
    Returns the number of expected parallel Subscribers.
    
    Specified by:
    
    parallelism in class ParallelFlowable<T>
    
    Returns:
    
    the number of expected parallel Subscribers