Package | Description |
---|---|
io.reactivex |
Base reactive classes:
Flowable , Observable ,
Single , Maybe and
Completable ; base reactive consumers;
other common base interfaces. |
io.reactivex.exceptions |
Exception handling utilities, safe subscriber exception classes,
lifecycle exception classes.
|
io.reactivex.parallel |
Contains the base type
ParallelFlowable ,
a sub-DSL for working with Flowable sequences in parallel. |
io.reactivex.plugins |
Contains the central plugin handler
RxJavaPlugins
class to hook into the lifecycle of the base reactive types and schedulers. |
Modifier and Type | Interface and Description |
---|---|
interface |
FlowableSubscriber<T>
Represents a Reactive-Streams inspired Subscriber that is RxJava 2 only
and weakens rules §1.3 and §3.9 of the specification for gaining performance.
|
Modifier and Type | Method and Description |
---|---|
<K,V> Flowable<GroupedFlowable<K,V>> |
Flowable.groupBy(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
boolean delayError,
int bufferSize,
Function<? super Consumer<Object>,? extends Map<K,Object>> evictingMapFactory)
Groups the items emitted by a
Publisher according to a specified criterion, and emits these
grouped items as GroupedFlowable s. |
ParallelFlowable<T> |
Flowable.parallel()
Parallelizes the flow by creating multiple 'rails' (equal to the number of CPUs)
and dispatches the upstream items to them in a round-robin fashion.
|
ParallelFlowable<T> |
Flowable.parallel(int parallelism)
Parallelizes the flow by creating the specified number of 'rails'
and dispatches the upstream items to them in a round-robin fashion.
|
ParallelFlowable<T> |
Flowable.parallel(int parallelism,
int prefetch)
Parallelizes the flow by creating the specified number of 'rails'
and dispatches the upstream items to them in a round-robin fashion and
uses the defined per-'rail' prefetch amount.
|
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 | Class and Description |
---|---|
class |
OnErrorNotImplementedException
Represents an exception used to signal to the
RxJavaPlugins.onError() that a
callback-based subscribe() method on a base reactive type didn't specify
an onError handler. |
class |
ProtocolViolationException
Explicitly named exception to indicate a Reactive-Streams
protocol violation.
|
class |
UndeliverableException
Wrapper for Throwable errors that are sent to `RxJavaPlugins.onError`.
|
Modifier and Type | Class and Description |
---|---|
class |
ParallelFlowable<T>
Abstract base class for Parallel publishers that take an array of Subscribers.
|
Modifier and Type | Method and Description |
---|---|
static Function<? super ParallelFlowable,? extends ParallelFlowable> |
RxJavaPlugins.getOnParallelAssembly()
Returns the current hook function.
|
static <T> ParallelFlowable<T> |
RxJavaPlugins.onAssembly(ParallelFlowable<T> source)
Calls the associated hook function.
|
static void |
RxJavaPlugins.setOnParallelAssembly(Function<? super ParallelFlowable,? extends ParallelFlowable> handler)
Sets the specific hook function.
|
Copyright © 2018 JBoss by Red Hat. All rights reserved.