Packages that use Beta

• Uses of Beta in rx

  Classes in with annotations of type

  Modifier and Type	Class and Description
  class	Single<T> The Single class implements the Reactive Pattern for a single value response.
  class	SingleSubscriber<T> Provides a mechanism for receiving push-based notifications.

  Methods in rx with annotations of type Beta

  Modifier and Type	Method and Description
  Observable<T>	Observable.doOnRequest(Action1<Long> onRequest) Modifies the source Observable so that it invokes the given action when it receives a request for more items.
  <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.
  <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.
  <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.
  Single<T>	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 Beta

  Modifier and Type	Class and Description
  interface	Beta 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

  Methods in rx.observables with annotations of type Beta

  Modifier and Type	Method and Description
  Observable<T>	ConnectableObservable.autoConnect() Returns an Observable that automatically connects to this ConnectableObservable when the first Subscriber subscribes.
  Observable<T>	ConnectableObservable.autoConnect(int numberOfSubscribers) Returns an Observable that automatically connects to this ConnectableObservable when the specified number of Subscribers subscribe to it.
  Observable<T>	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.

• Uses of Beta in rx.plugins

  Methods in rx.plugins with annotations of type Beta

  Modifier and Type	Method and Description
  String	RxJavaErrorHandler.handleOnNextValueRendering(Object item) Receives items causing OnErrorThrowable.OnNextValue and gives a chance to choose the String representation of the item in the OnNextValue stacktrace rendering.
  protected String	RxJavaErrorHandler.render(Object item) 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 Beta

  Modifier and Type	Method and Description
  Throwable	AsyncSubject.getThrowable() Returns the Throwable that terminated the Subject.
  Throwable	BehaviorSubject.getThrowable() Returns the Throwable that terminated the Subject.
  Throwable	PublishSubject.getThrowable() Returns the Throwable that terminated the Subject.
  Throwable	ReplaySubject.getThrowable() Returns the Throwable that terminated the Subject.
  T	AsyncSubject.getValue() Returns the current value of the Subject if there is such a value and the subject hasn't terminated with an exception.
  T	BehaviorSubject.getValue() Returns the current value of the Subject if there is such a value and the subject hasn't terminated yet.
  T	ReplaySubject.getValue()
  Object[]	BehaviorSubject.getValues() Returns a snapshot of the currently buffered non-terminal events.
  Object[]	ReplaySubject.getValues() Returns a snapshot of the currently buffered non-terminal events.
  T[]	BehaviorSubject.getValues(T[] a) Returns a snapshot of the currently buffered non-terminal events into the provided a array or creates a new array if it has not enough capacity.
  T[]	ReplaySubject.getValues(T[] a) Returns a snapshot of the currently buffered non-terminal events into the provided a 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.