Uses of Package
rx.internal.util
-
Packages that use rx.internal.util Package Description rx Base reactive classes: Observable, Single and Completable; base reactive consumers; other common base interfaces.rx.internal.operators Operators that allow composing Observables to transform and manipulate data in an asynchronous, functional and thread-safe manner.rx.internal.schedulers rx.internal.util rx.internal.util.unsafe -
Classes in rx.internal.util used by rx Class Description SubscriptionList Subscription that represents a group of Subscriptions that are unsubscribed together. -
Classes in rx.internal.util used by rx.internal.operators Class Description BackpressureDrainManager Manages the producer-backpressure-consumer interplay by matching up available elements with requested elements and/or terminal events.BackpressureDrainManager.BackpressureQueueCallback Interface representing the minimal callbacks required to operate the drain part of a backpressure system.LinkedArrayList A list implementation which combines an ArrayList with a LinkedList to avoid copying values when the capacity needs to be increased.OpenHashSet A simple open hash set with add, remove and clear capabilities only.RxRingBuffer This assumes Spsc or Spmc usage. -
Classes in rx.internal.util used by rx.internal.schedulers Class Description RxThreadFactory SubscriptionList Subscription that represents a group of Subscriptions that are unsubscribed together.SuppressAnimalSniffer Suppress errors by the AnimalSniffer plugin. -
Classes in rx.internal.util used by rx.internal.util.unsafe Class Description SuppressAnimalSniffer Suppress errors by the AnimalSniffer plugin.