Uses of Package
rx.internal.util
Packages that use rx.internal.util
Package
Description
Base reactive classes: Observable, Single and Completable; base reactive consumers;
other common base interfaces.
Operators that allow composing Observables to transform and
manipulate data in an asynchronous, functional and thread-safe manner.
-
Classes in rx.internal.util used by rxClassDescriptionSubscription that represents a group of Subscriptions that are unsubscribed together.
-
Classes in rx.internal.util used by rx.internal.operatorsClassDescriptionManages the producer-backpressure-consumer interplay by matching up available elements with requested elements and/or terminal events.Interface representing the minimal callbacks required to operate the drain part of a backpressure system.A list implementation which combines an ArrayList with a LinkedList to avoid copying values when the capacity needs to be increased.A simple open hash set with add, remove and clear capabilities only.This assumes Spsc or Spmc usage.
-
Classes in rx.internal.util used by rx.internal.schedulersClassDescriptionSubscription that represents a group of Subscriptions that are unsubscribed together.Suppress errors by the AnimalSniffer plugin.
-
Classes in rx.internal.util used by rx.internal.utilClassDescriptionInterface representing the minimal callbacks required to operate the drain part of a backpressure system.Utility methods for terminal atomics with Throwables.Add/Remove without object allocation (after initial construction).Holder of named utility classes factored out from Observable to save source space and help with debugging with properly named objects.This assumes Spsc or Spmc usage.An Observable that emits a single constant scalar value to Subscribers.
-
Classes in rx.internal.util used by rx.internal.util.unsafe