Package | Description |
---|---|
io.reactivex |
Base reactive classes:
Flowable , Observable ,
Single , Maybe and
Completable ; base reactive consumers;
other common base interfaces. |
io.reactivex.internal.operators.flowable | |
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 | Method and Description |
---|---|
ConnectableFlowable<T> |
Flowable.publish()
Returns a
ConnectableFlowable , which is a variety of Publisher that waits until its
connect method is called before it begins emitting items to those
Subscriber s that have subscribed to it. |
ConnectableFlowable<T> |
Flowable.publish(int bufferSize)
Returns a
ConnectableFlowable , which is a variety of Publisher that waits until its
connect method is called before it begins emitting items to those
Subscriber s that have subscribed to it. |
ConnectableFlowable<T> |
Flowable.replay()
Returns a
ConnectableFlowable that shares a single subscription to the underlying Publisher
that will replay all of its items and notifications to any future Subscriber . |
ConnectableFlowable<T> |
Flowable.replay(int bufferSize)
Returns a
ConnectableFlowable that shares a single subscription to the source Publisher that
replays at most bufferSize items emitted by that Publisher. |
ConnectableFlowable<T> |
Flowable.replay(int bufferSize,
long time,
TimeUnit unit)
Returns a
ConnectableFlowable that shares a single subscription to the source Publisher and
replays at most bufferSize items that were emitted during a specified time window. |
ConnectableFlowable<T> |
Flowable.replay(int bufferSize,
long time,
TimeUnit unit,
Scheduler scheduler)
Returns a
ConnectableFlowable that shares a single subscription to the source Publisher and
that replays a maximum of bufferSize items that are emitted within a specified time window. |
ConnectableFlowable<T> |
Flowable.replay(int bufferSize,
Scheduler scheduler)
Returns a
ConnectableFlowable that shares a single subscription to the source Publisher and
replays at most bufferSize items emitted by that Publisher. |
ConnectableFlowable<T> |
Flowable.replay(long time,
TimeUnit unit)
Returns a
ConnectableFlowable that shares a single subscription to the source Publisher and
replays all items emitted by that Publisher within a specified time window. |
ConnectableFlowable<T> |
Flowable.replay(long time,
TimeUnit unit,
Scheduler scheduler)
Returns a
ConnectableFlowable that shares a single subscription to the source Publisher and
replays all items emitted by that Publisher within a specified time window. |
ConnectableFlowable<T> |
Flowable.replay(Scheduler scheduler)
Returns a
ConnectableFlowable that shares a single subscription to the source Publisher that
will replay all of its items and notifications to any future Subscriber on the given
Scheduler . |
Modifier and Type | Class and Description |
---|---|
class |
FlowablePublish<T>
A connectable observable which shares an underlying source and dispatches source values to subscribers in a backpressure-aware
manner.
|
class |
FlowableReplay<T> |
Modifier and Type | Method and Description |
---|---|
static <T> ConnectableFlowable<T> |
FlowablePublish.create(Flowable<T> source,
int bufferSize)
Creates a OperatorPublish instance to publish values of the given source observable.
|
static <T> ConnectableFlowable<T> |
FlowableReplay.create(Flowable<T> source,
int bufferSize)
Creates a replaying ConnectableObservable with a size bound buffer.
|
static <T> ConnectableFlowable<T> |
FlowableReplay.create(Flowable<T> source,
long maxAge,
TimeUnit unit,
Scheduler scheduler)
Creates a replaying ConnectableObservable with a time bound buffer.
|
static <T> ConnectableFlowable<T> |
FlowableReplay.create(Flowable<T> source,
long maxAge,
TimeUnit unit,
Scheduler scheduler,
int bufferSize)
Creates a replaying ConnectableObservable with a size and time bound buffer.
|
static <T> ConnectableFlowable<T> |
FlowableReplay.createFrom(Flowable<? extends T> source)
Creates a replaying ConnectableObservable with an unbounded buffer.
|
static <T> ConnectableFlowable<T> |
FlowableReplay.observeOn(ConnectableFlowable<T> cf,
Scheduler scheduler)
Child Subscribers will observe the events of the ConnectableObservable on the
specified scheduler.
|
Modifier and Type | Method and Description |
---|---|
static <T> Callable<ConnectableFlowable<T>> |
FlowableInternalHelper.replayCallable(Flowable<T> parent) |
static <T> Callable<ConnectableFlowable<T>> |
FlowableInternalHelper.replayCallable(Flowable<T> parent,
int bufferSize) |
static <T> Callable<ConnectableFlowable<T>> |
FlowableInternalHelper.replayCallable(Flowable<T> parent,
int bufferSize,
long time,
TimeUnit unit,
Scheduler scheduler) |
static <T> Callable<ConnectableFlowable<T>> |
FlowableInternalHelper.replayCallable(Flowable<T> parent,
long time,
TimeUnit unit,
Scheduler scheduler) |
Modifier and Type | Method and Description |
---|---|
static <T> ConnectableFlowable<T> |
FlowableReplay.observeOn(ConnectableFlowable<T> cf,
Scheduler scheduler)
Child Subscribers will observe the events of the ConnectableObservable on the
specified scheduler.
|
Modifier and Type | Method and Description |
---|---|
static <U,R> Flowable<R> |
FlowableReplay.multicastSelector(Callable<? extends ConnectableFlowable<U>> connectableFactory,
Function<? super Flowable<U>,? extends org.reactivestreams.Publisher<R>> selector)
Given a connectable observable factory, it multicasts over the generated
ConnectableObservable via a selector function.
|
Constructor and Description |
---|
FlowableAutoConnect(ConnectableFlowable<? extends T> source,
int numberOfSubscribers,
Consumer<? super Disposable> connection) |
FlowableRefCount(ConnectableFlowable<T> source) |
FlowableRefCount(ConnectableFlowable<T> source,
int n,
long timeout,
TimeUnit unit,
Scheduler scheduler) |
Modifier and Type | Method and Description |
---|---|
static <T> ConnectableFlowable<T> |
RxJavaPlugins.onAssembly(ConnectableFlowable<T> source)
Calls the associated hook function.
|
Modifier and Type | Method and Description |
---|---|
static Function<? super ConnectableFlowable,? extends ConnectableFlowable> |
RxJavaPlugins.getOnConnectableFlowableAssembly()
Returns the current hook function.
|
static Function<? super ConnectableFlowable,? extends ConnectableFlowable> |
RxJavaPlugins.getOnConnectableFlowableAssembly()
Returns the current hook function.
|
Modifier and Type | Method and Description |
---|---|
static <T> ConnectableFlowable<T> |
RxJavaPlugins.onAssembly(ConnectableFlowable<T> source)
Calls the associated hook function.
|
Modifier and Type | Method and Description |
---|---|
static void |
RxJavaPlugins.setOnConnectableFlowableAssembly(Function<? super ConnectableFlowable,? extends ConnectableFlowable> onConnectableFlowableAssembly)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setOnConnectableFlowableAssembly(Function<? super ConnectableFlowable,? extends ConnectableFlowable> onConnectableFlowableAssembly)
Sets the specific hook function.
|
Copyright © 2018 JBoss by Red Hat. All rights reserved.