Package | Description |
---|---|
io.reactivex |
Base reactive classes:
Flowable , Observable ,
Single , Maybe and
Completable ; base reactive consumers;
other common base interfaces. |
io.reactivex.internal.disposables | |
io.reactivex.internal.operators.completable | |
io.reactivex.internal.operators.maybe | |
io.reactivex.internal.operators.mixed | |
io.reactivex.internal.operators.single |
Modifier and Type | Method and Description |
---|---|
Completable |
Completable.delaySubscription(long delay,
TimeUnit unit)
Returns a Completable that delays the subscription to the source CompletableSource by a given amount of time.
|
Completable |
Completable.delaySubscription(long delay,
TimeUnit unit,
Scheduler scheduler)
Returns a Completable that delays the subscription to the source CompletableSource by a given amount of time,
both waiting and subscribing on a given Scheduler.
|
<R> Maybe<R> |
Single.dematerialize(Function<? super T,Notification<R>> selector)
Maps the
Notification success value of this Single back into normal
onSuccess , onError or onComplete signals as a
Maybe source. |
<R> Observable<R> |
Observable.dematerialize(Function<? super T,Notification<R>> selector)
Returns an Observable that reverses the effect of
materialize by transforming the
Notification objects extracted from the source items via a selector function
into their respective Observer signal types. |
<R> Flowable<R> |
Flowable.dematerialize(Function<? super T,Notification<R>> selector)
Returns a Flowable that reverses the effect of
materialize by transforming the
Notification objects extracted from the source items via a selector function
into their respective Subscriber signal types. |
Single<Notification<T>> |
Single.materialize()
Maps the signal types of this Single into a
Notification of the same kind
and emits it as a single success value to downstream. |
Single<Notification<T>> |
Maybe.materialize()
Maps the signal types of this Maybe into a
Notification of the same kind
and emits it as a single success value to downstream. |
<T> Single<Notification<T>> |
Completable.materialize()
Maps the signal types of this Completable into a
Notification of the same kind
and emits it as a single success value to downstream. |
Modifier and Type | Interface and Description |
---|---|
interface |
ResettableConnectable
Interface allowing conditional resetting of connections in
ConnectableObservable s
and ConnectableFlowable s. |
Modifier and Type | Class and Description |
---|---|
class |
CompletableMaterialize<T>
Turn the signal types of a Completable source into a single Notification of
equal kind.
|
Modifier and Type | Class and Description |
---|---|
class |
MaybeMaterialize<T>
Turn the signal types of a Maybe source into a single Notification of
equal kind.
|
Modifier and Type | Class and Description |
---|---|
class |
MaterializeSingleObserver<T>
A consumer that implements the consumer types of Maybe, Single and Completable
and turns their signals into Notifications for a SingleObserver.
|
Modifier and Type | Class and Description |
---|---|
class |
SingleDematerialize<T,R>
Maps the success value of the source to a Notification, then
maps it back to the corresponding signal type.
|
class |
SingleMaterialize<T>
Turn the signal types of a Single source into a single Notification of
equal kind.
|
Copyright © 2019. All rights reserved.