Uses of Interface
io.reactivex.rxjava3.internal.util.AppendOnlyLinkedArrayList.NonThrowingPredicate

Packages that use AppendOnlyLinkedArrayList.NonThrowingPredicate

Package	Description
io.reactivex.rxjava3.internal.util
io.reactivex.rxjava3.processors	Classes representing so-called hot backpressure-aware sources, aka processors, that implement the FlowableProcessor class, the Reactive Streams Processor interface to allow forms of multicasting events to one or more subscribers as well as consuming another Reactive Streams Publisher.
io.reactivex.rxjava3.subjects	Classes representing so-called hot sources, aka subjects, that implement a base reactive class and the respective consumer type at once to allow forms of multicasting events to multiple consumers as well as consuming another base reactive type of their kind.

Uses of AppendOnlyLinkedArrayList.NonThrowingPredicate in io.reactivex.rxjava3.internal.util

Methods in io.reactivex.rxjava3.internal.util with parameters of type AppendOnlyLinkedArrayList.NonThrowingPredicate

Modifier and Type	Method	Description
void	AppendOnlyLinkedArrayList.forEachWhile(AppendOnlyLinkedArrayList.NonThrowingPredicate<? super T> consumer)	Loops over all elements of the array until a null element is encountered or the given predicate returns true.

Uses of AppendOnlyLinkedArrayList.NonThrowingPredicate in io.reactivex.rxjava3.processors

Classes in io.reactivex.rxjava3.processors that implement AppendOnlyLinkedArrayList.NonThrowingPredicate

Modifier and Type	Class	Description
(package private) static class	BehaviorProcessor.BehaviorSubscription<T>

Uses of AppendOnlyLinkedArrayList.NonThrowingPredicate in io.reactivex.rxjava3.subjects

Classes in io.reactivex.rxjava3.subjects that implement AppendOnlyLinkedArrayList.NonThrowingPredicate

Modifier and Type	Class	Description
(package private) static class	BehaviorSubject.BehaviorDisposable<T>
(package private) class	SerializedSubject<T>	Serializes calls to the Observer methods.