Package io.reactivex.rxjava3.internal.subscribers
package io.reactivex.rxjava3.internal.subscribers
-
ClassDescriptionBase class for a fuseable intermediate subscriber.Base class for a fuseable intermediate subscriber.Blocks until the upstream signals its first value or completes.Blocks until the upstream signals its last value or completes.A subscriber, extending a DeferredScalarSubscription, that is unbounded-in and can generate 0 or 1 resulting value.Wraps lambda callbacks and when the upstream terminates or this subscriber gets disposed, removes itself from a
CompositeDisposable
.A Subscriber + Future that expects exactly one upstream value and provides it via the (blocking) Future API.Subscriber that can fuse with the upstream and calls a support interface whenever an event is available.Interface to allow the InnerQueuedSubscriber to call back a parent with signals.QueueDrainSubscriber<T,U, V> Abstract base class for subscribers that hold another subscriber, a queue and requires queue-drain behavior.Pads the header away from other fields.Pads away the wip from the other fields.Contains the requested field.Pads away the requested from the other fields.The WIP counter.Relays signals from upstream according to downstream requests and allows signalling a final value followed by onComplete in a backpressure-aware manner.Ensures that the event flow between the upstream and downstream follow the Reactive-Streams 1.0 specification by honoring the 3 additional rules (which are omitted in standard operators due to performance reasons).