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