hu.akarnokd.rxjava2

Class Single<T>

java.lang.Object

hu.akarnokd.rxjava2.Single<T>

Type Parameters:

T - the value type

public class Single<T>
extends java.lang.Object

Represents a deferred computation and emission of a single value or exception.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	Single.SingleOnSubscribe<T>
static interface	Single.SingleOperator<Downstream,Upstream>
static interface	Single.SingleSubscriber<T>
static interface	Single.SingleTransformer<Upstream,Downstream>

Field Summary

Fields

Modifier and Type	Field and Description
protected Single.SingleOnSubscribe<T>	onSubscribe

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	Single(Single.SingleOnSubscribe<T> onSubscribe)

Method Summary

Modifier and Type	Method and Description
static <T> Single<T>	amb(java.lang.Iterable<? extends Single<? extends T>> sources)
static <T> Single<T>	amb(Single<? extends T>... sources)
Single<T>	ambWith(Single<? extends T> other)
Single<T>	asSingle()
Single<T>	cache()
<U> Single<U>	cast(java.lang.Class<? extends U> clazz)
<R> Single<R>	compose(Function<? super Single<T>,? extends Single<R>> convert)
static <T> Observable<T>	concat(java.lang.Iterable<? extends Single<? extends T>> sources)
static <T> Observable<T>	concat(Observable<? extends Single<? extends T>> sources)
static <T> Observable<T>	concat(Single<? extends T> s1, Single<? extends T> s2)
static <T> Observable<T>	concat(Single<? extends T> s1, Single<? extends T> s2, Single<? extends T> s3)
static <T> Observable<T>	concat(Single<? extends T> s1, Single<? extends T> s2, Single<? extends T> s3, Single<? extends T> s4)
static <T> Observable<T>	concat(Single<? extends T> s1, Single<? extends T> s2, Single<? extends T> s3, Single<? extends T> s4, Single<? extends T> s5)
static <T> Observable<T>	concat(Single<? extends T> s1, Single<? extends T> s2, Single<? extends T> s3, Single<? extends T> s4, Single<? extends T> s5, Single<? extends T> s6)
static <T> Observable<T>	concat(Single<? extends T> s1, Single<? extends T> s2, Single<? extends T> s3, Single<? extends T> s4, Single<? extends T> s5, Single<? extends T> s6, Single<? extends T> s7)
static <T> Observable<T>	concat(Single<? extends T> s1, Single<? extends T> s2, Single<? extends T> s3, Single<? extends T> s4, Single<? extends T> s5, Single<? extends T> s6, Single<? extends T> s7, Single<? extends T> s8)
static <T> Observable<T>	concat(Single<? extends T> s1, Single<? extends T> s2, Single<? extends T> s3, Single<? extends T> s4, Single<? extends T> s5, Single<? extends T> s6, Single<? extends T> s7, Single<? extends T> s8, Single<? extends T> s9)
Observable<T>	concatWith(Single<? extends T> other)
Single<java.lang.Boolean>	contains(java.lang.Object value)
Single<java.lang.Boolean>	contains(java.lang.Object value, BiPredicate<java.lang.Object,java.lang.Object> comparer)
static <T> Single<T>	create(Single.SingleOnSubscribe<T> onSubscribe)
static <T> Single<T>	defer(Supplier<? extends Single<? extends T>> singleSupplier)
Single<T>	delay(long time, java.util.concurrent.TimeUnit unit)
Single<T>	delay(long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
Single<T>	doOnCancel(java.lang.Runnable onCancel)
Single<T>	doOnError(Consumer<? super java.lang.Throwable> onError)
Single<T>	doOnSubscribe(Consumer<? super Disposable> onSubscribe)
Single<T>	doOnSuccess(Consumer<? super T> onSuccess)
static <T> Single<java.lang.Boolean>	equals(Single<? extends T> first, Single<? extends T> second)
static <T> Single<T>	error(Supplier<? extends java.lang.Throwable> errorSupplier)
static <T> Single<T>	error(java.lang.Throwable error)
<R> Single<R>	flatMap(Function<? super T,? extends Single<? extends R>> mapper)
<R> Observable<R>	flatMapPublisher(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper)
static <T> Single<T>	fromCallable(java.util.concurrent.Callable<? extends T> callable)
static <T> Single<T>	fromFuture(java.util.concurrent.Future<? extends T> future)
static <T> Single<T>	fromFuture(java.util.concurrent.Future<? extends T> future, long timeout, java.util.concurrent.TimeUnit unit)
static <T> Single<T>	fromFuture(java.util.concurrent.Future<? extends T> future, long timeout, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
static <T> Single<T>	fromFuture(java.util.concurrent.Future<? extends T> future, Scheduler scheduler)
static <T> Single<T>	fromPublisher(org.reactivestreams.Publisher<? extends T> publisher)
T	get()
static <T> Single<T>	just(T value)
<R> Single<R>	lift(Single.SingleOperator<? extends R,? super T> onLift)
<R> Single<R>	map(Function<? super T,? extends R> mapper)
static <T> Observable<T>	merge(java.lang.Iterable<? extends Single<? extends T>> sources)
static <T> Observable<T>	merge(Observable<? extends Single<? extends T>> sources)
static <T> Single<T>	merge(Single<? extends Single<? extends T>> source)
static <T> Observable<T>	merge(Single<? extends T> s1, Single<? extends T> s2)
static <T> Observable<T>	merge(Single<? extends T> s1, Single<? extends T> s2, Single<? extends T> s3)
static <T> Observable<T>	merge(Single<? extends T> s1, Single<? extends T> s2, Single<? extends T> s3, Single<? extends T> s4)
static <T> Observable<T>	merge(Single<? extends T> s1, Single<? extends T> s2, Single<? extends T> s3, Single<? extends T> s4, Single<? extends T> s5)
static <T> Observable<T>	merge(Single<? extends T> s1, Single<? extends T> s2, Single<? extends T> s3, Single<? extends T> s4, Single<? extends T> s5, Single<? extends T> s6)
static <T> Observable<T>	merge(Single<? extends T> s1, Single<? extends T> s2, Single<? extends T> s3, Single<? extends T> s4, Single<? extends T> s5, Single<? extends T> s6, Single<? extends T> s7)
static <T> Observable<T>	merge(Single<? extends T> s1, Single<? extends T> s2, Single<? extends T> s3, Single<? extends T> s4, Single<? extends T> s5, Single<? extends T> s6, Single<? extends T> s7, Single<? extends T> s8)
static <T> Observable<T>	merge(Single<? extends T> s1, Single<? extends T> s2, Single<? extends T> s3, Single<? extends T> s4, Single<? extends T> s5, Single<? extends T> s6, Single<? extends T> s7, Single<? extends T> s8, Single<? extends T> s9)
Observable<T>	mergeWith(Single<? extends T> other)
Single<Single<T>>	nest()
static <T> Single<T>	never()
Single<T>	observeOn(Scheduler scheduler)
Single<T>	onErrorResumeNext(Function<? super java.lang.Throwable,? extends Single<? extends T>> nextFunction)
Single<T>	onErrorReturn(Supplier<? extends T> valueSupplier)
Single<T>	onErrorReturn(T value)
Observable<T>	repeat()
Observable<T>	repeat(long times)
Observable<T>	repeatUntil(BooleanSupplier stop)
Observable<T>	repeatWhen(Function<? super Observable<java.lang.Object>,? extends org.reactivestreams.Publisher<java.lang.Object>> handler)
Single<T>	retry()
Single<T>	retry(BiPredicate<? super java.lang.Integer,? super java.lang.Throwable> predicate)
Single<T>	retry(long times)
Single<T>	retry(Predicate<? super java.lang.Throwable> predicate)
Single<T>	retryWhen(Function<? super Observable<? extends java.lang.Throwable>,? extends org.reactivestreams.Publisher<java.lang.Object>> handler)
void	safeSubscribe(org.reactivestreams.Subscriber<? super T> s)
Disposable	subscribe()
Disposable	subscribe(BiConsumer<? super T,? super java.lang.Throwable> onCallback)
Disposable	subscribe(Consumer<? super T> onSuccess)
Disposable	subscribe(Consumer<? super T> onSuccess, Consumer<? super java.lang.Throwable> onError)
void	subscribe(Single.SingleSubscriber<? super T> subscriber)
void	subscribe(org.reactivestreams.Subscriber<? super T> s)
Single<T>	subscribeOn(Scheduler scheduler)
Single<T>	timeout(long timeout, java.util.concurrent.TimeUnit unit)
Single<T>	timeout(long timeout, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
Single<T>	timeout(long timeout, java.util.concurrent.TimeUnit unit, Scheduler scheduler, Single<? extends T> other)
Single<T>	timeout(long timeout, java.util.concurrent.TimeUnit unit, Single<? extends T> other)
static Single<java.lang.Long>	timer(long delay, java.util.concurrent.TimeUnit unit)
static Single<java.lang.Long>	timer(long delay, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
<R> R	to(Function<? super Single<T>,R> convert)
Observable<T>	toFlowable()
void	unsafeSubscribe(org.reactivestreams.Subscriber<? super T> s)
static <T,U> Single<T>	using(Supplier<U> resourceSupplier, Function<? super U,? extends Single<? extends T>> singleFunction, Consumer<? super U> disposer)
static <T,U> Single<T>	using(Supplier<U> resourceSupplier, Function<? super U,? extends Single<? extends T>> singleFunction, Consumer<? super U> disposer, boolean eager)
static <T,R> Single<R>	zip(java.lang.Iterable<? extends Single<? extends T>> sources, Function<? super java.lang.Object[],? extends R> zipper)
static <T1,T2,R> Single<R>	zip(Single<? extends T1> s1, Single<? extends T2> s2, BiFunction<? super T1,? super T2,? extends R> zipper)
static <T1,T2,T3,R> Single<R>	zip(Single<? extends T1> s1, Single<? extends T2> s2, Single<? extends T3> s3, Function3<? super T1,? super T2,? super T3,? extends R> zipper)
static <T1,T2,T3,T4,R> Single<R>	zip(Single<? extends T1> s1, Single<? extends T2> s2, Single<? extends T3> s3, Single<? extends T4> s4, Function4<? super T1,? super T2,? super T3,? super T4,? extends R> zipper)
static <T1,T2,T3,T4,T5,R> Single<R>	zip(Single<? extends T1> s1, Single<? extends T2> s2, Single<? extends T3> s3, Single<? extends T4> s4, Single<? extends T5> s5, Function5<? super T1,? super T2,? super T3,? super T4,? super T5,? extends R> zipper)
static <T1,T2,T3,T4,T5,T6,R> Single<R>	zip(Single<? extends T1> s1, Single<? extends T2> s2, Single<? extends T3> s3, Single<? extends T4> s4, Single<? extends T5> s5, Single<? extends T6> s6, Function6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> zipper)
static <T1,T2,T3,T4,T5,T6,T7,R> Single<R>	zip(Single<? extends T1> s1, Single<? extends T2> s2, Single<? extends T3> s3, Single<? extends T4> s4, Single<? extends T5> s5, Single<? extends T6> s6, Single<? extends T7> s7, Function7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> zipper)
static <T1,T2,T3,T4,T5,T6,T7,T8,R> Single<R>	zip(Single<? extends T1> s1, Single<? extends T2> s2, Single<? extends T3> s3, Single<? extends T4> s4, Single<? extends T5> s5, Single<? extends T6> s6, Single<? extends T7> s7, Single<? extends T8> s8, Function8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> zipper)
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> Single<R>	zip(Single<? extends T1> s1, Single<? extends T2> s2, Single<? extends T3> s3, Single<? extends T4> s4, Single<? extends T5> s5, Single<? extends T6> s6, Single<? extends T7> s7, Single<? extends T8> s8, Single<? extends T9> s9, Function9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> zipper)
static <T,R> Single<R>	zipArray(Function<? super java.lang.Object[],? extends R> zipper, Single<? extends T>... sources)
<U,R> Single<R>	zipWith(Single<U> other, BiFunction<? super T,? super U,? extends R> zipper)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

onSubscribe

protected final Single.SingleOnSubscribe<T> onSubscribe

Constructor Detail

Single

protected Single(Single.SingleOnSubscribe<T> onSubscribe)

Method Detail

amb

public static <T> Single<T> amb(java.lang.Iterable<? extends Single<? extends T>> sources)

amb

public static <T> Single<T> amb(Single<? extends T>... sources)

concat

public static <T> Observable<T> concat(java.lang.Iterable<? extends Single<? extends T>> sources)

concat

public static <T> Observable<T> concat(Observable<? extends Single<? extends T>> sources)

concat

public static <T> Observable<T> concat(Single<? extends T> s1,
                                       Single<? extends T> s2)

concat

public static <T> Observable<T> concat(Single<? extends T> s1,
                                       Single<? extends T> s2,
                                       Single<? extends T> s3)

concat

public static <T> Observable<T> concat(Single<? extends T> s1,
                                       Single<? extends T> s2,
                                       Single<? extends T> s3,
                                       Single<? extends T> s4)

concat

public static <T> Observable<T> concat(Single<? extends T> s1,
                                       Single<? extends T> s2,
                                       Single<? extends T> s3,
                                       Single<? extends T> s4,
                                       Single<? extends T> s5)

concat

public static <T> Observable<T> concat(Single<? extends T> s1,
                                       Single<? extends T> s2,
                                       Single<? extends T> s3,
                                       Single<? extends T> s4,
                                       Single<? extends T> s5,
                                       Single<? extends T> s6)

concat

public static <T> Observable<T> concat(Single<? extends T> s1,
                                       Single<? extends T> s2,
                                       Single<? extends T> s3,
                                       Single<? extends T> s4,
                                       Single<? extends T> s5,
                                       Single<? extends T> s6,
                                       Single<? extends T> s7)

concat

public static <T> Observable<T> concat(Single<? extends T> s1,
                                       Single<? extends T> s2,
                                       Single<? extends T> s3,
                                       Single<? extends T> s4,
                                       Single<? extends T> s5,
                                       Single<? extends T> s6,
                                       Single<? extends T> s7,
                                       Single<? extends T> s8)

concat

public static <T> Observable<T> concat(Single<? extends T> s1,
                                       Single<? extends T> s2,
                                       Single<? extends T> s3,
                                       Single<? extends T> s4,
                                       Single<? extends T> s5,
                                       Single<? extends T> s6,
                                       Single<? extends T> s7,
                                       Single<? extends T> s8,
                                       Single<? extends T> s9)

create

public static <T> Single<T> create(Single.SingleOnSubscribe<T> onSubscribe)

defer

public static <T> Single<T> defer(Supplier<? extends Single<? extends T>> singleSupplier)

error

public static <T> Single<T> error(Supplier<? extends java.lang.Throwable> errorSupplier)

error

public static <T> Single<T> error(java.lang.Throwable error)

fromCallable

public static <T> Single<T> fromCallable(java.util.concurrent.Callable<? extends T> callable)

fromFuture

public static <T> Single<T> fromFuture(java.util.concurrent.Future<? extends T> future)

fromFuture

public static <T> Single<T> fromFuture(java.util.concurrent.Future<? extends T> future,
                                       long timeout,
                                       java.util.concurrent.TimeUnit unit)

fromFuture

public static <T> Single<T> fromFuture(java.util.concurrent.Future<? extends T> future,
                                       long timeout,
                                       java.util.concurrent.TimeUnit unit,
                                       Scheduler scheduler)

fromFuture

public static <T> Single<T> fromFuture(java.util.concurrent.Future<? extends T> future,
                                       Scheduler scheduler)

fromPublisher

public static <T> Single<T> fromPublisher(org.reactivestreams.Publisher<? extends T> publisher)

just

public static <T> Single<T> just(T value)

merge

public static <T> Observable<T> merge(java.lang.Iterable<? extends Single<? extends T>> sources)

merge

public static <T> Observable<T> merge(Observable<? extends Single<? extends T>> sources)

merge

public static <T> Single<T> merge(Single<? extends Single<? extends T>> source)

merge

public static <T> Observable<T> merge(Single<? extends T> s1,
                                      Single<? extends T> s2)

merge

public static <T> Observable<T> merge(Single<? extends T> s1,
                                      Single<? extends T> s2,
                                      Single<? extends T> s3)

merge

public static <T> Observable<T> merge(Single<? extends T> s1,
                                      Single<? extends T> s2,
                                      Single<? extends T> s3,
                                      Single<? extends T> s4)

merge

public static <T> Observable<T> merge(Single<? extends T> s1,
                                      Single<? extends T> s2,
                                      Single<? extends T> s3,
                                      Single<? extends T> s4,
                                      Single<? extends T> s5)

merge

public static <T> Observable<T> merge(Single<? extends T> s1,
                                      Single<? extends T> s2,
                                      Single<? extends T> s3,
                                      Single<? extends T> s4,
                                      Single<? extends T> s5,
                                      Single<? extends T> s6)

merge

public static <T> Observable<T> merge(Single<? extends T> s1,
                                      Single<? extends T> s2,
                                      Single<? extends T> s3,
                                      Single<? extends T> s4,
                                      Single<? extends T> s5,
                                      Single<? extends T> s6,
                                      Single<? extends T> s7)

merge

public static <T> Observable<T> merge(Single<? extends T> s1,
                                      Single<? extends T> s2,
                                      Single<? extends T> s3,
                                      Single<? extends T> s4,
                                      Single<? extends T> s5,
                                      Single<? extends T> s6,
                                      Single<? extends T> s7,
                                      Single<? extends T> s8)

merge

public static <T> Observable<T> merge(Single<? extends T> s1,
                                      Single<? extends T> s2,
                                      Single<? extends T> s3,
                                      Single<? extends T> s4,
                                      Single<? extends T> s5,
                                      Single<? extends T> s6,
                                      Single<? extends T> s7,
                                      Single<? extends T> s8,
                                      Single<? extends T> s9)

never

public static <T> Single<T> never()

timer

public static Single<java.lang.Long> timer(long delay,
                                           java.util.concurrent.TimeUnit unit)

timer

public static Single<java.lang.Long> timer(long delay,
                                           java.util.concurrent.TimeUnit unit,
                                           Scheduler scheduler)

equals

public static <T> Single<java.lang.Boolean> equals(Single<? extends T> first,
                                                   Single<? extends T> second)

using

public static <T,U> Single<T> using(Supplier<U> resourceSupplier,
                                    Function<? super U,? extends Single<? extends T>> singleFunction,
                                    Consumer<? super U> disposer)

using

public static <T,U> Single<T> using(Supplier<U> resourceSupplier,
                                    Function<? super U,? extends Single<? extends T>> singleFunction,
                                    Consumer<? super U> disposer,
                                    boolean eager)

zip

public static <T,R> Single<R> zip(java.lang.Iterable<? extends Single<? extends T>> sources,
                                  Function<? super java.lang.Object[],? extends R> zipper)

zip

public static <T1,T2,R> Single<R> zip(Single<? extends T1> s1,
                                      Single<? extends T2> s2,
                                      BiFunction<? super T1,? super T2,? extends R> zipper)

zip

public static <T1,T2,T3,R> Single<R> zip(Single<? extends T1> s1,
                                         Single<? extends T2> s2,
                                         Single<? extends T3> s3,
                                         Function3<? super T1,? super T2,? super T3,? extends R> zipper)

zip

public static <T1,T2,T3,T4,R> Single<R> zip(Single<? extends T1> s1,
                                            Single<? extends T2> s2,
                                            Single<? extends T3> s3,
                                            Single<? extends T4> s4,
                                            Function4<? super T1,? super T2,? super T3,? super T4,? extends R> zipper)

zip

public static <T1,T2,T3,T4,T5,R> Single<R> zip(Single<? extends T1> s1,
                                               Single<? extends T2> s2,
                                               Single<? extends T3> s3,
                                               Single<? extends T4> s4,
                                               Single<? extends T5> s5,
                                               Function5<? super T1,? super T2,? super T3,? super T4,? super T5,? extends R> zipper)

zip

public static <T1,T2,T3,T4,T5,T6,R> Single<R> zip(Single<? extends T1> s1,
                                                  Single<? extends T2> s2,
                                                  Single<? extends T3> s3,
                                                  Single<? extends T4> s4,
                                                  Single<? extends T5> s5,
                                                  Single<? extends T6> s6,
                                                  Function6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> zipper)

zip

public static <T1,T2,T3,T4,T5,T6,T7,R> Single<R> zip(Single<? extends T1> s1,
                                                     Single<? extends T2> s2,
                                                     Single<? extends T3> s3,
                                                     Single<? extends T4> s4,
                                                     Single<? extends T5> s5,
                                                     Single<? extends T6> s6,
                                                     Single<? extends T7> s7,
                                                     Function7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> zipper)

zip

public static <T1,T2,T3,T4,T5,T6,T7,T8,R> Single<R> zip(Single<? extends T1> s1,
                                                        Single<? extends T2> s2,
                                                        Single<? extends T3> s3,
                                                        Single<? extends T4> s4,
                                                        Single<? extends T5> s5,
                                                        Single<? extends T6> s6,
                                                        Single<? extends T7> s7,
                                                        Single<? extends T8> s8,
                                                        Function8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> zipper)

zip

public static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> Single<R> zip(Single<? extends T1> s1,
                                                           Single<? extends T2> s2,
                                                           Single<? extends T3> s3,
                                                           Single<? extends T4> s4,
                                                           Single<? extends T5> s5,
                                                           Single<? extends T6> s6,
                                                           Single<? extends T7> s7,
                                                           Single<? extends T8> s8,
                                                           Single<? extends T9> s9,
                                                           Function9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> zipper)

zipArray

public static <T,R> Single<R> zipArray(Function<? super java.lang.Object[],? extends R> zipper,
                                       Single<? extends T>... sources)

ambWith

public final Single<T> ambWith(Single<? extends T> other)

asSingle

public final Single<T> asSingle()

compose

public final <R> Single<R> compose(Function<? super Single<T>,? extends Single<R>> convert)

cache

public final Single<T> cache()

cast

public final <U> Single<U> cast(java.lang.Class<? extends U> clazz)

concatWith

public final Observable<T> concatWith(Single<? extends T> other)

delay

public final Single<T> delay(long time,
                             java.util.concurrent.TimeUnit unit)

delay

public final Single<T> delay(long time,
                             java.util.concurrent.TimeUnit unit,
                             Scheduler scheduler)

doOnSubscribe

public final Single<T> doOnSubscribe(Consumer<? super Disposable> onSubscribe)

doOnSuccess

public final Single<T> doOnSuccess(Consumer<? super T> onSuccess)

doOnError

public final Single<T> doOnError(Consumer<? super java.lang.Throwable> onError)

doOnCancel

public final Single<T> doOnCancel(java.lang.Runnable onCancel)

flatMap

public final <R> Single<R> flatMap(Function<? super T,? extends Single<? extends R>> mapper)

flatMapPublisher

public final <R> Observable<R> flatMapPublisher(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper)

get

public final T get()

lift

public final <R> Single<R> lift(Single.SingleOperator<? extends R,? super T> onLift)

map

public final <R> Single<R> map(Function<? super T,? extends R> mapper)

contains

public final Single<java.lang.Boolean> contains(java.lang.Object value)

contains

public final Single<java.lang.Boolean> contains(java.lang.Object value,
                                                BiPredicate<java.lang.Object,java.lang.Object> comparer)

mergeWith

public final Observable<T> mergeWith(Single<? extends T> other)

nest

public final Single<Single<T>> nest()

observeOn

public final Single<T> observeOn(Scheduler scheduler)

onErrorReturn

public final Single<T> onErrorReturn(Supplier<? extends T> valueSupplier)

onErrorReturn

public final Single<T> onErrorReturn(T value)

onErrorResumeNext

public final Single<T> onErrorResumeNext(Function<? super java.lang.Throwable,? extends Single<? extends T>> nextFunction)

repeat

public final Observable<T> repeat()

repeat

public final Observable<T> repeat(long times)

repeatWhen

public final Observable<T> repeatWhen(Function<? super Observable<java.lang.Object>,? extends org.reactivestreams.Publisher<java.lang.Object>> handler)

repeatUntil

public final Observable<T> repeatUntil(BooleanSupplier stop)

retry

public final Single<T> retry()

retry

public final Single<T> retry(long times)

retry

public final Single<T> retry(BiPredicate<? super java.lang.Integer,? super java.lang.Throwable> predicate)

retry

public final Single<T> retry(Predicate<? super java.lang.Throwable> predicate)

retryWhen

public final Single<T> retryWhen(Function<? super Observable<? extends java.lang.Throwable>,? extends org.reactivestreams.Publisher<java.lang.Object>> handler)

safeSubscribe

public final void safeSubscribe(org.reactivestreams.Subscriber<? super T> s)

subscribe

public final Disposable subscribe()

subscribe

public final Disposable subscribe(BiConsumer<? super T,? super java.lang.Throwable> onCallback)

subscribe

public final Disposable subscribe(Consumer<? super T> onSuccess)

subscribe

public final Disposable subscribe(Consumer<? super T> onSuccess,
                                  Consumer<? super java.lang.Throwable> onError)

subscribe

public final void subscribe(Single.SingleSubscriber<? super T> subscriber)

subscribe

public final void subscribe(org.reactivestreams.Subscriber<? super T> s)

subscribeOn

public final Single<T> subscribeOn(Scheduler scheduler)

timeout

public final Single<T> timeout(long timeout,
                               java.util.concurrent.TimeUnit unit)

timeout

public final Single<T> timeout(long timeout,
                               java.util.concurrent.TimeUnit unit,
                               Scheduler scheduler)

timeout

public final Single<T> timeout(long timeout,
                               java.util.concurrent.TimeUnit unit,
                               Scheduler scheduler,
                               Single<? extends T> other)

timeout

public final Single<T> timeout(long timeout,
                               java.util.concurrent.TimeUnit unit,
                               Single<? extends T> other)

to

public final <R> R to(Function<? super Single<T>,R> convert)

toFlowable

public final Observable<T> toFlowable()

unsafeSubscribe

public final void unsafeSubscribe(org.reactivestreams.Subscriber<? super T> s)

zipWith

public final <U,R> Single<R> zipWith(Single<U> other,
                                     BiFunction<? super T,? super U,? extends R> zipper)