Packages that use Experimental

• Uses of Experimental in rx

  Methods in rx with annotations of type Experimental

  Modifier and Type	Method and Description
  static <T> Observable<T>	Observable.concatEager(Iterable<? extends Observable<? extends T>> sources) Concatenates a sequence of Observables eagerly into a single stream of values.
  static <T> Observable<T>	Observable.concatEager(Iterable<? extends Observable<? extends T>> sources, int capacityHint) Concatenates a sequence of Observables eagerly into a single stream of values.
  static <T> Observable<T>	Observable.concatEager(Observable<? extends Observable<? extends T>> sources) Concatenates an Observable sequence of Observables eagerly into a single stream of values.
  static <T> Observable<T>	Observable.concatEager(Observable<? extends Observable<? extends T>> sources, int capacityHint) Concatenates an Observable sequence of Observables eagerly into a single stream of values.
  static <T> Observable<T>	Observable.concatEager(Observable<? extends T> o1, Observable<? extends T> o2) Concatenates two source Observables eagerly into a single stream of values.
  static <T> Observable<T>	Observable.concatEager(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3) Concatenates three sources eagerly into a single stream of values.
  static <T> Observable<T>	Observable.concatEager(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4) Concatenates four sources eagerly into a single stream of values.
  static <T> Observable<T>	Observable.concatEager(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4, Observable<? extends T> o5) Concatenates five sources eagerly into a single stream of values.
  static <T> Observable<T>	Observable.concatEager(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4, Observable<? extends T> o5, Observable<? extends T> o6) Concatenates six sources eagerly into a single stream of values.
  static <T> Observable<T>	Observable.concatEager(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4, Observable<? extends T> o5, Observable<? extends T> o6, Observable<? extends T> o7) Concatenates seven sources eagerly into a single stream of values.
  static <T> Observable<T>	Observable.concatEager(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4, Observable<? extends T> o5, Observable<? extends T> o6, Observable<? extends T> o7, Observable<? extends T> o8) Concatenates eight sources eagerly into a single stream of values.
  static <T> Observable<T>	Observable.concatEager(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4, Observable<? extends T> o5, Observable<? extends T> o6, Observable<? extends T> o7, Observable<? extends T> o8, Observable<? extends T> o9) Concatenates nine sources eagerly into a single stream of values.
  <R> Observable<R>	Observable.concatMapEager(Func1<? super T,? extends Observable<? extends R>> mapper) Maps a sequence of values into Observables and concatenates these Observables eagerly into a single Observable.
  <R> Observable<R>	Observable.concatMapEager(Func1<? super T,? extends Observable<? extends R>> mapper, int capacityHint) Maps a sequence of values into Observables and concatenates these Observables eagerly into a single Observable.
  static <T> Single<T>	Single.defer(Callable<Single<T>> singleFactory) Returns a Single that calls a Single factory to create a Single for each new Observer that subscribes.
  Single<T>	Single.delay(long delay, TimeUnit unit) Returns an Single that emits the items emitted by the source Single shifted forward in time by a specified delay.
  Single<T>	Single.delay(long delay, TimeUnit unit, Scheduler scheduler) Returns an Single that emits the items emitted by the source Single shifted forward in time by a specified delay.
  Single<T>	Single.doOnError(Action1<Throwable> onError) Modifies the source Single so that it invokes an action if it calls onError.
  Single<T>	Single.doOnSuccess(Action1<? super T> onSuccess) Modifies the source Single so that it invokes an action when it calls onSuccess.
  <R> R	Observable.extend(Func1<? super Observable.OnSubscribe<T>,? extends R> conversion) Passes all emitted values from this Observable to the provided conversion function to be collected and returned as a single value.
  static <T> Single<T>	Single.fromCallable(Callable<? extends T> func) Returns a Single that invokes passed function and emits its result for each new Observer that subscribes.
  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> Observable<T>	Observable.mergeDelayError(Observable<? extends Observable<? extends T>> source, int maxConcurrent) Flattens an Observable that emits Observables into one Observable, in a way that allows an Observer to receive all successfully emitted items from all of the source Observables without being interrupted by an error notification from one of them, while limiting the number of concurrent subscriptions to these Observables.
  BlockingSingle<T>	Single.toBlocking() Converts a Single into a BlockingSingle (a Single with blocking operators).
  Observable<List<T>>	Observable.toSortedList(Func2<? super T,? super T,Integer> sortFunction, int initialCapacity) Returns an Observable that emits a list that contains the items emitted by the source Observable, in a sorted order based on a specified comparison function.
  Observable<List<T>>	Observable.toSortedList(int initialCapacity) Returns an Observable that emits a list that contains the items emitted by the source Observable, in a sorted order.
  static <T,Resource> Observable<T>	Observable.using(Func0<Resource> resourceFactory, Func1<? super Resource,? extends Observable<? extends T>> observableFactory, Action1<? super Resource> disposeAction, boolean disposeEagerly) Constructs an Observable that creates a dependent resource object which is disposed of just before termination if you have set disposeEagerly to true and unsubscription does not occur before termination.
  <U,R> Observable<R>	Observable.withLatestFrom(Observable<? extends U> other, Func2<? super T,? super U,? extends R> resultSelector) Merges the specified Observable into this Observable sequence by using the resultSelector function only when the source Observable (this instance) emits an item.

• Uses of Experimental in rx.annotations

  Classes in rx.annotations with annotations of type Experimental

  Modifier and Type	Class and Description
  interface	Experimental Signifies that a public API (public class, method or field) is will almost certainly be changed or removed in a future release.

• Uses of Experimental in rx.exceptions

  Methods in rx.exceptions with annotations of type Experimental

  Modifier and Type	Method and Description
  static void	Exceptions.throwOrReport(Throwable t, Observer<?> o) Forwards a fatal exception or reports it to the given Observer.
  static void	Exceptions.throwOrReport(Throwable t, Observer<?> o, Object value) Forwards a fatal exception or reports it along with the value caused it to the given Observer.

• Uses of Experimental in rx.internal.util

  Classes in with annotations of type

  Modifier and Type	Class and Description
  class	BackpressureDrainManager Manages the producer-backpressure-consumer interplay by matching up available elements with requested elements and/or terminal events.
  class	BlockingUtils Utility functions relating to blocking types.

  Methods in rx.internal.util with annotations of type Experimental

  Modifier and Type	Method and Description
  static void	BlockingUtils.awaitForComplete(CountDownLatch latch, Subscription subscription) Blocks and waits for a Subscription to complete.

• Uses of Experimental in rx.observables

  Classes in with annotations of type

  Modifier and Type	Class and Description
  class	AsyncOnSubscribe<S,T> A utility class to create OnSubscribe<T> functions that respond correctly to back pressure requests from subscribers.
  class	SyncOnSubscribe<S,T> A utility class to create OnSubscribe<T> functions that respond correctly to back pressure requests from subscribers.

  Methods in rx.observables with annotations of type Experimental

  Modifier and Type	Method and Description
  static <S,T> Observable.OnSubscribe<T>	SyncOnSubscribe.createSingleState(Func0<? extends S> generator, Action2<? super S,? super Observer<? super T>> next) Generates a synchronous SyncOnSubscribe that calls the provided next function to generate data to downstream subscribers.
  static <S,T> Observable.OnSubscribe<T>	SyncOnSubscribe.createSingleState(Func0<? extends S> generator, Action2<? super S,? super Observer<? super T>> next, Action1<? super S> onUnsubscribe) Generates a synchronous SyncOnSubscribe that calls the provided next function to generate data to downstream subscribers.
  static <S,T> Observable.OnSubscribe<T>	AsyncOnSubscribe.createSingleState(Func0<? extends S> generator, Action3<? super S,Long,? super Observer<Observable<? extends T>>> next) Generates a synchronous AsyncOnSubscribe that calls the provided next function to generate data to downstream subscribers.
  static <S,T> Observable.OnSubscribe<T>	AsyncOnSubscribe.createSingleState(Func0<? extends S> generator, Action3<? super S,Long,? super Observer<Observable<? extends T>>> next, Action1<? super S> onUnsubscribe) Generates a synchronous AsyncOnSubscribe that calls the provided next function to generate data to downstream subscribers.
  static <S,T> Observable.OnSubscribe<T>	SyncOnSubscribe.createStateful(Func0<? extends S> generator, Func2<? super S,? super Observer<? super T>,? extends S> next) Generates a synchronous SyncOnSubscribe that calls the provided next function to generate data to downstream subscribers.
  static <S,T> Observable.OnSubscribe<T>	SyncOnSubscribe.createStateful(Func0<? extends S> generator, Func2<? super S,? super Observer<? super T>,? extends S> next, Action1<? super S> onUnsubscribe) Generates a synchronous SyncOnSubscribe that calls the provided next function to generate data to downstream subscribers.
  static <S,T> Observable.OnSubscribe<T>	AsyncOnSubscribe.createStateful(Func0<? extends S> generator, Func3<? super S,Long,? super Observer<Observable<? extends T>>,? extends S> next) Generates a synchronous AsyncOnSubscribe that calls the provided next function to generate data to downstream subscribers.
  static <S,T> Observable.OnSubscribe<T>	AsyncOnSubscribe.createStateful(Func0<? extends S> generator, Func3<? super S,Long,? super Observer<Observable<? extends T>>,? extends S> next, Action1<? super S> onUnsubscribe) Generates a synchronous AsyncOnSubscribe that calls the provided next function to generate data to downstream subscribers.
  static <T> Observable.OnSubscribe<T>	SyncOnSubscribe.createStateless(Action1<? super Observer<? super T>> next) Generates a synchronous SyncOnSubscribe that calls the provided next function to generate data to downstream subscribers.
  static <T> Observable.OnSubscribe<T>	SyncOnSubscribe.createStateless(Action1<? super Observer<? super T>> next, Action0 onUnsubscribe) Generates a synchronous SyncOnSubscribe that calls the provided next function to generate data to downstream subscribers.
  static <T> Observable.OnSubscribe<T>	AsyncOnSubscribe.createStateless(Action2<Long,? super Observer<Observable<? extends T>>> next) Generates a synchronous AsyncOnSubscribe that calls the provided next function to generate data to downstream subscribers.
  static <T> Observable.OnSubscribe<T>	AsyncOnSubscribe.createStateless(Action2<Long,? super Observer<Observable<? extends T>>> next, Action0 onUnsubscribe) Generates a synchronous AsyncOnSubscribe that calls the provided next function to generate data to downstream subscribers.
  void	BlockingObservable.subscribe() Runs the source observable to a terminal event, ignoring any values and rethrowing any exception.
  void	BlockingObservable.subscribe(Action1<? super T> onNext) Subscribes to the source and calls the given action on the current thread and rethrows any exception wrapped into OnErrorNotImplementedException.
  void	BlockingObservable.subscribe(Action1<? super T> onNext, Action1<? super Throwable> onError) Subscribes to the source and calls the given actions on the current thread.
  void	BlockingObservable.subscribe(Action1<? super T> onNext, Action1<? super Throwable> onError, Action0 onCompleted) Subscribes to the source and calls the given actions on the current thread.
  void	BlockingObservable.subscribe(Observer<? super T> observer) Subscribes to the source and calls back the Observer methods on the current thread.
  void	BlockingObservable.subscribe(Subscriber<? super T> subscriber) Subscribes to the source and calls the Subscriber methods on the current thread.

• Uses of Experimental in rx.singles

  Classes in with annotations of type

  Modifier and Type	Class and Description
  class	BlockingSingle<T> BlockingSingle is a blocking "version" of Single that provides blocking operators.

  Methods in rx.singles with annotations of type Experimental

  Modifier and Type	Method and Description
  static <T> BlockingSingle<T>	BlockingSingle.from(Single<? extends T> single) Converts a Single into a BlockingSingle.
  Future<T>	BlockingSingle.toFuture() Returns a Future representing the value emitted by this BlockingSingle.
  T	BlockingSingle.value() Returns the item emitted by this BlockingSingle.