Uses of Interface
com.forgerock.reactive.Single
-
Packages that use Single Package Description com.forgerock.reactive Provides asynchronous stream processing with non-blocking back pressure. -
-
Uses of Single in com.forgerock.reactive
Methods in com.forgerock.reactive that return Single Modifier and Type Method Description <O> Single<O>Single. flatMap(org.forgerock.util.Function<V,Single<O>,Exception> function)Transforms asynchronously the value emitted by this single into another.<O> Single<O>Single. map(org.forgerock.util.Function<V,O,Exception> function)Transforms the value emitted by this single.static <V> Single<V>RxJavaStreams. newSingle(Single.Emitter<V> emitter)Creates a bridge from callback world toSingle.Single<V>Single. onErrorResumeWith(org.forgerock.util.Function<Throwable,Single<V>,Exception> function)When an error occurs in this stream, continue the processing with the newSingleprovided by the function.static <V> Single<V>RxJavaStreams. singleError(Throwable error)Create a newSinglefrom the given error.static <V> Single<V>RxJavaStreams. singleFrom(V value)Create a newSinglefrom the given value.static <V> Single<V>RxJavaStreams. singleFromPublisher(org.reactivestreams.Publisher<V> publisher)Create a newSinglefrom the givenPublisher.<V> Single<V>Completable. toSingle(V value)Returns aSinglewhich will complete with the provided value once thisCompletablecompletes.Method parameters in com.forgerock.reactive with type arguments of type Single Modifier and Type Method Description <O> Single<O>Single. flatMap(org.forgerock.util.Function<V,Single<O>,Exception> function)Transforms asynchronously the value emitted by this single into another.Single<V>Single. onErrorResumeWith(org.forgerock.util.Function<Throwable,Single<V>,Exception> function)When an error occurs in this stream, continue the processing with the newSingleprovided by the function.
-