Uses of Interface
io.reactivex.rxjava3.core.FlowableSubscriber
Packages that use FlowableSubscriber
Package
Description
Base reactive classes:
Flowable
, Observable
,
Single
, Maybe
and
Completable
; base reactive consumers;
other common base interfaces.Classes and interfaces for writing advanced operators within and outside RxJava.
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
.Default wrappers and implementations for
Subscriber
-based consumer classes and interfaces,
including disposable (DisposableSubscriber
) and resource-tracking
(ResourceSubscriber
)
variants and the TestSubscriber
that allows unit testing
Flowable
-based flows.-
Uses of FlowableSubscriber in io.reactivex.rxjava3.core
Methods in io.reactivex.rxjava3.core with parameters of type FlowableSubscriberModifier and TypeMethodDescriptionfinal void
Flowable.subscribe
(@NonNull FlowableSubscriber<? super @NonNull T> subscriber) Establish a connection between thisFlowable
and the givenFlowableSubscriber
and start streaming events based on the demand of theFlowableSubscriber
. -
Uses of FlowableSubscriber in io.reactivex.rxjava3.internal.jdk8
Classes in io.reactivex.rxjava3.internal.jdk8 that implement FlowableSubscriberModifier and TypeClassDescription(package private) static final class
(package private) static final class
final class
Signals the first element of the source via the underlying CompletableFuture, signals the a default item if the upstream is empty or signalsNoSuchElementException
.(package private) static final class
final class
Signals the last element of the source via the underlying CompletableFuture, signals the a default item if the upstream is empty or signalsNoSuchElementException
.(package private) static final class
(package private) static final class
final class
Signals the only element of the source via the underlying CompletableFuture, signals the a default item if the upstream is empty or signalsIllegalArgumentException
if the upstream has more than one item.(package private) class
Base class that extends CompletableFuture and provides basic infrastructure to notify watchers upon upstream signals.(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
-
Uses of FlowableSubscriber in io.reactivex.rxjava3.internal.operators.completable
Classes in io.reactivex.rxjava3.internal.operators.completable that implement FlowableSubscriberModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) static final class
-
Uses of FlowableSubscriber in io.reactivex.rxjava3.internal.operators.flowable
Classes in io.reactivex.rxjava3.internal.operators.flowable that implement FlowableSubscriberModifier and TypeClassDescription(package private) class
Abstract base class for operators that throttle excessive updates from upstream in case if downstreamSubscriber
is not ready to receive updates.(package private) static final class
(package private) static final class
Subscriber of source, iterator for output.(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
FlowableBuffer.PublisherBufferExactSubscriber<T,
C extends Collection<? super T>> (package private) static final class
FlowableBuffer.PublisherBufferOverlappingSubscriber<T,
C extends Collection<? super T>> (package private) static final class
FlowableBuffer.PublisherBufferSkipSubscriber<T,
C extends Collection<? super T>> (package private) static final class
FlowableBufferBoundary.BufferBoundarySubscriber<T,
C extends Collection<? super T>, Open, Close> (package private) static final class
(package private) static final class
FlowableBufferBoundary.BufferCloseSubscriber<T,
C extends Collection<? super T>> (package private) static final class
FlowableBufferExactBoundary.BufferBoundarySubscriber<T,
U extends Collection<? super T>, B> (package private) static final class
FlowableBufferExactBoundary.BufferExactBoundarySubscriber<T,
U extends Collection<? super T>, B> (package private) static final class
FlowableBufferTimed.BufferExactBoundedSubscriber<T,
U extends Collection<? super T>> (package private) static final class
FlowableBufferTimed.BufferExactUnboundedSubscriber<T,
U extends Collection<? super T>> (package private) static final class
FlowableBufferTimed.BufferSkipBoundedSubscriber<T,
U extends Collection<? super T>> final class
An observable which auto-connects to another observable, caches the elements from that observable but allows terminating the connection and completing the cache.(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
FlowableToList.ToListSubscriber<T,
U extends Collection<? super T>> (package private) static final class
FlowableToListSingle.ToListSubscriber<T,
U extends Collection<? super T>> (package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
Methods in io.reactivex.rxjava3.internal.operators.flowable that return FlowableSubscriberModifier and TypeMethodDescriptionstatic <T,
U> FlowableSubscriber <T> FlowableFlatMap.subscribe
(org.reactivestreams.Subscriber<? super U> s, Function<? super T, ? extends org.reactivestreams.Publisher<? extends U>> mapper, boolean delayErrors, int maxConcurrency, int bufferSize) -
Uses of FlowableSubscriber in io.reactivex.rxjava3.internal.operators.maybe
Classes in io.reactivex.rxjava3.internal.operators.maybe that implement FlowableSubscriberModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
-
Uses of FlowableSubscriber in io.reactivex.rxjava3.internal.operators.mixed
Classes in io.reactivex.rxjava3.internal.operators.mixed that implement FlowableSubscriberModifier and TypeClassDescription(package private) static final class
class
Base class for implementing concatMapX main subscribers.(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
-
Uses of FlowableSubscriber in io.reactivex.rxjava3.internal.operators.observable
Classes in io.reactivex.rxjava3.internal.operators.observable that implement FlowableSubscriberModifier and TypeClassDescription(package private) static final class
-
Uses of FlowableSubscriber in io.reactivex.rxjava3.internal.operators.parallel
Classes in io.reactivex.rxjava3.internal.operators.parallel that implement FlowableSubscriberModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) static final class
(package private) static class
(package private) static final class
(package private) static final class
(package private) static class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static class
(package private) static final class
(package private) static final class
(package private) static final class
-
Uses of FlowableSubscriber in io.reactivex.rxjava3.internal.operators.single
Classes in io.reactivex.rxjava3.internal.operators.single that implement FlowableSubscriberModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
-
Uses of FlowableSubscriber in io.reactivex.rxjava3.internal.subscribers
Classes in io.reactivex.rxjava3.internal.subscribers that implement FlowableSubscriberModifier and TypeClassDescriptionclass
Base class for a fuseable intermediate subscriber.class
Base class for a fuseable intermediate subscriber.class
final class
Blocks until the upstream signals its first value or completes.final class
Blocks until the upstream signals its last value or completes.final class
final class
class
A subscriber, extending a DeferredScalarSubscription, that is unbounded-in and can generate 0 or 1 resulting value.final class
Wraps lambda callbacks and when the upstream terminates or this subscriber gets disposed, removes itself from aCompositeDisposable
.final class
final class
A Subscriber + Future that expects exactly one upstream value and provides it via the (blocking) Future API.final class
Subscriber that can fuse with the upstream and calls a support interface whenever an event is available.final class
class
QueueDrainSubscriber<T,
U, V> Abstract base class for subscribers that hold another subscriber, a queue and requires queue-drain behavior.class
Relays signals from upstream according to downstream requests and allows signalling a final value followed by onComplete in a backpressure-aware manner.class
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).final class
-
Uses of FlowableSubscriber in io.reactivex.rxjava3.internal.util
Classes in io.reactivex.rxjava3.internal.util that implement FlowableSubscriberModifier and TypeClassDescriptionenum
Singleton implementing many interfaces as empty. -
Uses of FlowableSubscriber in io.reactivex.rxjava3.operators
Subinterfaces of FlowableSubscriber in io.reactivex.rxjava3.operatorsModifier and TypeInterfaceDescriptioninterface
AFlowableSubscriber
with an additionalConditionalSubscriber.tryOnNext(Object)
method that tells the caller the specified value has been accepted or not. -
Uses of FlowableSubscriber in io.reactivex.rxjava3.processors
Classes in io.reactivex.rxjava3.processors that implement FlowableSubscriberModifier and TypeClassDescriptionfinal class
Processor that emits the very last value followed by a completion event or the received error toSubscriber
s.final class
Processor that emits the most recent item it has observed and all subsequent observed items to each subscribedSubscriber
.class
Represents a Subscriber and a Flowable (Publisher) at the same time, allowing multicasting events from a single source to multiple child Subscribers.final class
AFlowableProcessor
implementation that coordinates downstream requests through a front-buffer and stable-prefetching, optionally canceling the upstream if all subscribers have cancelled.final class
Processor that multicasts all subsequently observed items to its currentSubscriber
s.final class
Replays events to Subscribers.(package private) final class
Serializes calls to the Subscriber methods.final class
AFlowableProcessor
variant that queues up events until a singleSubscriber
subscribes to it, replays those events to it until theSubscriber
catches up and then switches to relaying events live to this singleSubscriber
until thisUnicastProcessor
terminates or theSubscriber
cancels its subscription. -
Uses of FlowableSubscriber in io.reactivex.rxjava3.subscribers
Classes in io.reactivex.rxjava3.subscribers that implement FlowableSubscriberModifier and TypeClassDescriptionclass
Abstract base implementation of aSubscriber
with support for requesting viaDefaultSubscriber.request(long)
, cancelling via viaDefaultSubscriber.cancel()
(both synchronously) and callsDefaultSubscriber.onStart()
when the subscription happens.class
An abstract Subscriber that allows asynchronous, external cancellation by implementingDisposable
.class
An abstract Subscriber that allows asynchronous cancellation of its subscription and associated resources.final class
Wraps anotherSubscriber
and ensures allonXXX
methods conform the protocol (except the requirement for serialized access).final class
Serializes access to theSubscriber.onNext(Object)
,Subscriber.onError(Throwable)
andSubscriber.onComplete()
methods of anotherSubscriber
.class
ASubscriber
implementation that records events and allows making assertions about them.(package private) static enum
A subscriber that ignores all events and does not report errors.