Package | Description |
---|---|
io.reactivex |
Base reactive classes:
Flowable , Observable ,
Single , Maybe and
Completable ; base reactive consumers;
other common base interfaces. |
io.reactivex.internal.fuseable |
Base interfaces and types for supporting operator-fusion.
|
io.reactivex.internal.operators.flowable | |
io.reactivex.internal.subscribers | |
io.reactivex.internal.util | |
io.reactivex.processors |
Classes extending the Flowable base reactive class and implementing
the Subscriber interface at the same time (aka hot Flowables).
|
io.reactivex.subscribers |
Default wrappers and implementations for Subscriber-based consumer classes and interfaces,
including disposable and resource-tracking variants and
the
TestSubscriber that allows unit testing
Flowable -based flows. |
Modifier and Type | Method and Description |
---|---|
void |
Flowable.subscribe(FlowableSubscriber<? super T> s)
Establish a connection between this Flowable and the given FlowableSubscriber and
start streaming events based on the demand of the FlowableSubscriber.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ConditionalSubscriber<T>
A Subscriber with an additional
ConditionalSubscriber.tryOnNext(Object) method that
tells the caller the specified value has been accepted or
not. |
Modifier and Type | Class and Description |
---|---|
class |
FlowableCache<T>
An observable which auto-connects to another observable, caches the elements
from that observable but allows terminating the connection and completing the cache.
|
static class |
FlowableGroupBy.GroupBySubscriber<T,K,V> |
Modifier and Type | Method and Description |
---|---|
static <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) |
Modifier and Type | Class and Description |
---|---|
class |
BasicFuseableConditionalSubscriber<T,R>
Base class for a fuseable intermediate subscriber.
|
class |
BasicFuseableSubscriber<T,R>
Base class for a fuseable intermediate subscriber.
|
class |
BlockingBaseSubscriber<T> |
class |
BlockingFirstSubscriber<T>
Blocks until the upstream signals its first value or completes.
|
class |
BlockingLastSubscriber<T>
Blocks until the upstream signals its last value or completes.
|
class |
BlockingSubscriber<T> |
class |
BoundedSubscriber<T> |
class |
DeferredScalarSubscriber<T,R>
A subscriber, extending a DeferredScalarSubscription,
that is unbounded-in and can generate 0 or 1 resulting value.
|
class |
ForEachWhileSubscriber<T> |
class |
FutureSubscriber<T>
A Subscriber + Future that expects exactly one upstream value and provides it
via the (blocking) Future API.
|
class |
InnerQueuedSubscriber<T>
Subscriber that can fuse with the upstream and calls a support interface
whenever an event is available.
|
class |
LambdaSubscriber<T> |
class |
QueueDrainSubscriber<T,U,V>
Abstract base class for subscribers that hold another subscriber, a queue
and requires queue-drain behavior.
|
class |
SinglePostCompleteSubscriber<T,R>
Relays signals from upstream according to downstream requests and allows
signalling a final value followed by onComplete in a backpressure-aware manner.
|
class |
StrictSubscriber<T>
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).
|
class |
SubscriberResourceWrapper<T> |
Modifier and Type | Class and Description |
---|---|
class |
EmptyComponent
Singleton implementing many interfaces as empty.
|
Modifier and Type | Class and Description |
---|---|
class |
AsyncProcessor<T>
Processor that emits the very last value followed by a completion event or the received error
to
Subscriber s. |
class |
BehaviorProcessor<T>
Processor that emits the most recent item it has observed and all subsequent observed items to each subscribed
Subscriber . |
class |
FlowableProcessor<T>
Represents a Subscriber and a Flowable (Publisher) at the same time, allowing
multicasting events from a single source to multiple child Subscribers.
|
class |
MulticastProcessor<T>
A
FlowableProcessor implementation that coordinates downstream requests through
a front-buffer and stable-prefetching, optionally canceling the upstream if all
subscribers have cancelled. |
class |
PublishProcessor<T>
Processor that multicasts all subsequently observed items to its current
Subscriber s. |
class |
ReplayProcessor<T>
Replays events to Subscribers.
|
class |
UnicastProcessor<T>
A
FlowableProcessor variant that queues up events until a single Subscriber subscribes to it, replays
those events to it until the Subscriber catches up and then switches to relaying events live to
this single Subscriber until this UnicastProcessor terminates or the Subscriber cancels
its subscription. |
Modifier and Type | Class and Description |
---|---|
class |
DefaultSubscriber<T>
Abstract base implementation of a
Subscriber with
support for requesting via DefaultSubscriber.request(long) , cancelling via
via DefaultSubscriber.cancel() (both synchronously) and calls DefaultSubscriber.onStart()
when the subscription happens. |
class |
DisposableSubscriber<T>
An abstract Subscriber that allows asynchronous, external cancellation by implementing Disposable.
|
class |
ResourceSubscriber<T>
An abstract Subscriber that allows asynchronous cancellation of its
subscription and associated resources.
|
class |
SafeSubscriber<T>
Wraps another Subscriber and ensures all onXXX methods conform the protocol
(except the requirement for serialized access).
|
class |
SerializedSubscriber<T>
Serializes access to the onNext, onError and onComplete methods of another Subscriber.
|
class |
TestSubscriber<T>
A subscriber that records events and allows making assertions about them.
|
Copyright © 2019. All rights reserved.