Uses of Annotation Interface
rx.annotations.Beta
Packages that use Beta
Package
Description
Base reactive classes: Observable, Single and Completable; base reactive consumers;
other common base interfaces.
Annotations for indicating experimental and beta operators, classes, methods, types or fields.
Classes extending the Observable base reactive class, synchronous and
asynchronous event generators.
Callback types and a central plugin handler class to hook into the lifecycle
of the base reactive types and schedulers.
Classes extending the Observable base reactive class and implementing
the Observer interface at the same time (aka hot Observables).
-
Uses of Beta in rx
Modifier and TypeClassDescriptionclass
Single<T>
The Single class implements the Reactive Pattern for a single value response.class
Provides a mechanism for receiving push-based notifications.Modifier and TypeMethodDescriptionstatic <S,
T> Observable <T> Observable.create
(SyncOnSubscribe<S, T> syncOnSubscribe) Returns an Observable that respects the back-pressure semantics.final Observable
<T> Observable.doOnRequest
(Action1<Long> onRequest) Modifies the sourceObservable
so that it invokes the given action when it receives a request for more items.final <R> Observable
<R> Observable.flatMap
(Func1<? super T, ? extends Observable<? extends R>> func, int maxConcurrent) Returns an Observable that emits items based on applying a function that you supply to each item emitted by the source Observable, where that function returns an Observable, and then merging those resulting Observables and emitting the results of this merger, while limiting the maximum number of concurrent subscriptions to these Observables.final <R> Observable
<R> Observable.flatMap
(Func1<? super T, ? extends Observable<? extends R>> onNext, Func1<? super Throwable, ? extends Observable<? extends R>> onError, Func0<? extends Observable<? extends R>> onCompleted, int maxConcurrent) Returns an Observable that applies a function to each item emitted or notification raised by the source Observable and then flattens the Observables returned from these functions and emits the resulting items, while limiting the maximum number of concurrent subscriptions to these Observables.final <U,
R> Observable <R> Observable.flatMap
(Func1<? super T, ? extends Observable<? extends U>> collectionSelector, Func2<? super T, ? super U, ? extends R> resultSelector, int maxConcurrent) Returns an Observable that emits the results of a specified function to the pair of values emitted by the source Observable and a specified collection Observable, while limiting the maximum number of concurrent subscriptions to these Observables.final <R> Observable
<R> Observable.flatMapIterable
(Func1<? super T, ? extends Iterable<? extends R>> collectionSelector, int maxConcurrent) Returns an Observable that merges each item emitted by the source Observable with the values in an Iterable corresponding to that item that is generated by a selector, while limiting the number of concurrent subscriptions to these Observables.final <U,
R> Observable <R> Observable.flatMapIterable
(Func1<? super T, ? extends Iterable<? extends U>> collectionSelector, Func2<? super T, ? super U, ? extends R> resultSelector, int maxConcurrent) Returns an Observable that emits the results of applying a function to the pair of values from the source Observable and an Iterable corresponding to that item that is generated by a selector, while limiting the number of concurrent subscriptions to these Observables.static <T> Observable
<T> Observable.fromCallable
(Callable<? extends T> func) Returns an Observable that, when an observer subscribes to it, invokes a function you specify and then emits the value returned from that function.static <T> Single
<T> Single.fromCallable
(Callable<? extends T> func) Returns aSingle
that invokes passed function and emits its result for each new Observer that subscribes.Observable.toSingle()
Returns a Single that emits the single item emitted by the source Observable, if that Observable emits only a single item. -
Uses of Beta in rx.annotations
Classes in rx.annotations with annotations of type BetaModifier and TypeClassDescription@interface
Signifies that a public API (public class, method or field) is subject to incompatible changes, or even removal, in a future release. -
Uses of Beta in rx.observables
Classes in rx.observables with annotations of type BetaModifier and TypeClassDescriptionclass
SyncOnSubscribe<S,
T> A utility class to createOnSubscribe<T>
functions that respond correctly to back pressure requests from subscribers.Methods in rx.observables with annotations of type BetaModifier and TypeMethodDescriptionConnectableObservable.autoConnect()
Returns an Observable that automatically connects to this ConnectableObservable when the first Subscriber subscribes.ConnectableObservable.autoConnect
(int numberOfSubscribers) Returns an Observable that automatically connects to this ConnectableObservable when the specified number of Subscribers subscribe to it.ConnectableObservable.autoConnect
(int numberOfSubscribers, Action1<? super Subscription> connection) Returns an Observable that automatically connects to this ConnectableObservable when the specified number of Subscribers subscribe to it and calls the specified callback with the Subscription associated with the established connection.static <S,
T> SyncOnSubscribe <S, T> SyncOnSubscribe.createSingleState
(Func0<? extends S> generator, Action2<? super S, ? super Observer<? super T>> next) Generates a synchronousSyncOnSubscribe
that calls the providednext
function to generate data to downstream subscribers.static <S,
T> SyncOnSubscribe <S, T> SyncOnSubscribe.createSingleState
(Func0<? extends S> generator, Action2<? super S, ? super Observer<? super T>> next, Action1<? super S> onUnsubscribe) Generates a synchronousSyncOnSubscribe
that calls the providednext
function to generate data to downstream subscribers.static <S,
T> SyncOnSubscribe <S, T> SyncOnSubscribe.createStateful
(Func0<? extends S> generator, Func2<? super S, ? super Observer<? super T>, ? extends S> next) Generates a synchronousSyncOnSubscribe
that calls the providednext
function to generate data to downstream subscribers.static <S,
T> SyncOnSubscribe <S, T> SyncOnSubscribe.createStateful
(Func0<? extends S> generator, Func2<? super S, ? super Observer<? super T>, ? extends S> next, Action1<? super S> onUnsubscribe) Generates a synchronousSyncOnSubscribe
that calls the providednext
function to generate data to downstream subscribers.static <T> SyncOnSubscribe
<Void, T> SyncOnSubscribe.createStateless
(Action1<? super Observer<? super T>> next) Generates a synchronousSyncOnSubscribe
that calls the providednext
function to generate data to downstream subscribers.static <T> SyncOnSubscribe
<Void, T> SyncOnSubscribe.createStateless
(Action1<? super Observer<? super T>> next, Action0 onUnsubscribe) Generates a synchronousSyncOnSubscribe
that calls the providednext
function to generate data to downstream subscribers. -
Uses of Beta in rx.plugins
Methods in rx.plugins with annotations of type BetaModifier and TypeMethodDescriptionfinal String
RxJavaErrorHandler.handleOnNextValueRendering
(Object item) Receives items causingOnErrorThrowable.OnNextValue
and gives a chance to choose the String representation of the item in theOnNextValue
stacktrace rendering.protected String
Override this method to provide rendering for specific types other than primitive types and null. -
Uses of Beta in rx.subjects
Methods in rx.subjects with annotations of type BetaModifier and TypeMethodDescriptionAsyncSubject.getThrowable()
Returns the Throwable that terminated the Subject.BehaviorSubject.getThrowable()
Returns the Throwable that terminated the Subject.PublishSubject.getThrowable()
Returns the Throwable that terminated the Subject.ReplaySubject.getThrowable()
Returns the Throwable that terminated the Subject.AsyncSubject.getValue()
Returns the current value of the Subject if there is such a value and the subject hasn't terminated with an exception.BehaviorSubject.getValue()
Returns the current value of the Subject if there is such a value and the subject hasn't terminated yet.ReplaySubject.getValue()
Object[]
BehaviorSubject.getValues()
Returns a snapshot of the currently buffered non-terminal events.T[]
Returns a snapshot of the currently buffered non-terminal events into the provideda
array or creates a new array if it has not enough capacity.Object[]
ReplaySubject.getValues()
Returns a snapshot of the currently buffered non-terminal events.T[]
Returns a snapshot of the currently buffered non-terminal events into the provideda
array or creates a new array if it has not enough capacity.boolean
ReplaySubject.hasAnyValue()
boolean
AsyncSubject.hasCompleted()
Check if the Subject has terminated normally.boolean
BehaviorSubject.hasCompleted()
Check if the Subject has terminated normally.boolean
PublishSubject.hasCompleted()
Check if the Subject has terminated normally.boolean
ReplaySubject.hasCompleted()
Check if the Subject has terminated normally.boolean
AsyncSubject.hasThrowable()
Check if the Subject has terminated with an exception.boolean
BehaviorSubject.hasThrowable()
Check if the Subject has terminated with an exception.boolean
PublishSubject.hasThrowable()
Check if the Subject has terminated with an exception.boolean
ReplaySubject.hasThrowable()
Check if the Subject has terminated with an exception.boolean
AsyncSubject.hasValue()
Check if the Subject has a value.boolean
BehaviorSubject.hasValue()
Check if the Subject has a value.boolean
ReplaySubject.hasValue()
int
ReplaySubject.size()
Returns the current number of items (non-terminal events) available for replay.