Package rx.internal.util
package rx.internal.util
-
ClassDescriptionAn Observer that forwards the onXXX method calls to a notification callback by transforming each signal type into Notifications.A Subscriber that forwards the onXXX method calls to callbacks.Manages 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.Utility functions relating to blocking types.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.A list implementation which combines an ArrayList with a LinkedList to avoid copying values when the capacity needs to be increased.ObjectPool<T>Wraps an Observer and forwards the onXXX method calls to it.OpenHashSet<T>A simple open hash set with add, remove and clear capabilities only.Allow platform dependent logic such as checks for Android.This assumes Spsc or Spmc usage.An Observable that emits a single constant scalar value to Subscribers.The OnSubscribe callback for the Observable constructor.The OnSubscribe implementation that creates the ScalarAsyncProducer for each incoming subscriber.Represents a producer which schedules the emission of a scalar value on the first positive request via the given scheduler callback.This is the weak version of SingleProducer that uses plain fields to avoid reentrancy and as such is not threadsafe for concurrent request() calls.Optimized observeOn for scalar value observed on the EventLoopsScheduler.Emits a scalar value on a general scheduler.Action that emits a single value when called.Subscription that represents a group of Subscriptions that are unsubscribed together.Suppress errors by the AnimalSniffer plugin.Intended for use when the `sun.misc.Unsafe` implementations can't be used.Utility functions for internal use that we don't want part of the public API.