public interface Single<T> extends StreamIterable<T>
Modifier and Type | Method and Description |
---|---|
default Single<T> |
doOnError(Consumer<? super Throwable> consumer) |
default Single<T> |
doOnValue(Consumer<? super T> consumer) |
static <T> Single<T> |
error(Callable<? extends Throwable> callable) |
static <T> Single<T> |
error(Throwable error) |
default <R> Stream<R> |
flatMap(Function<? super T,? extends StreamIterable<? extends R>> mapper) |
default <R> Maybe<R> |
flatMapMaybe(Function<? super T,? extends Maybe<? extends R>> mapper) |
default void |
forEach() |
static <T> Single<T> |
fromCallable(Callable<? extends T> callable) |
T |
get() |
default void |
go() |
default StreamIterator<T> |
iterator() |
default <R> Single<R> |
map(Function<? super T,? extends R> mapper) |
static <T> Single<T> |
of(T t) |
default Single<T> |
println() |
default Stream<T> |
repeat() |
default RetryWhenBuilderSingle<T> |
retryWhen() |
default Single<T> |
retryWhen(Function<? super Throwable,? extends Single<?>> function) |
default void |
start() |
default <R> Single<T> |
switchOnError(Function<? super Throwable,? extends Single<? extends T>> function) |
default SingleTester<T> |
test() |
static Single<Integer> |
timer(long duration,
TimeUnit unit) |
static <T> Single<T> |
timer(T t,
long duration,
TimeUnit unit) |
default <R> R |
to(Function<? super Single<T>,R> mapper) |
default Stream<T> |
toStream() |
iteratorNullChecked
forEach, spliterator
T get()
static <T> Single<T> of(T t)
default <R> Stream<R> flatMap(Function<? super T,? extends StreamIterable<? extends R>> mapper)
default <R> Maybe<R> flatMapMaybe(Function<? super T,? extends Maybe<? extends R>> mapper)
default <R> Single<T> switchOnError(Function<? super Throwable,? extends Single<? extends T>> function)
default SingleTester<T> test()
default StreamIterator<T> iterator()
default void forEach()
default void go()
default void start()
default RetryWhenBuilderSingle<T> retryWhen()
Copyright © 2018–2023. All rights reserved.