Method Detail

• create

   static <T> Observable<T> create(Observable.OnSubscribe<T> onSubscribe)

• subscribe

   final Subscription subscribe(Subscriber<out Object> subscriber)

• subscribe

   final Subscription subscribe()

• subscribe

   final Subscription subscribe(Action1<out Object> onNext)

• subscribe

   final Subscription subscribe(Action1<out Object> onNext, Action1<Throwable> onError)

• subscribe

   final Subscription subscribe(Action1<out Object> onNext, Action1<Throwable> onError, Action0 onCompleted)

• subscribe

   final Subscription subscribe(Observer<out Object> observer)

• subscribeOn

   final Observable<T> subscribeOn(Scheduler scheduler)

  Asynchronously subscribes Observers to this Observable on the specified Scheduler.

  If there is a type source up in thechain, it is recommended to use {@code subscribeOn(scheduler, false)} insteadto avoid same-pool deadlock because requests pile up behind a eager/blocking emitter.

  Parameters:

  scheduler - the Scheduler to perform subscription actions on

• subscribeOn

   final Observable<T> subscribeOn(Scheduler scheduler, boolean requestOn)

• unsafeCreate

   static <T> Observable<T> unsafeCreate(Observable.OnSubscribe<T> f)

• unsafeSubscribe

   final Subscription unsafeSubscribe(Subscriber<out Object> subscriber)

• observeOn

   Observable<T> observeOn(Scheduler scheduler)

  Modifies an Observable to perform its emissions and notifications on a specified Scheduler,asynchronously with a bounded buffer of slots.

  Note that onError notifications will cut ahead of onNext notifications on the emission thread if Scheduler is trulyasynchronous. If strict event ordering is required, consider using the observeOn(Scheduler, boolean) overload.

  Parameters:

  scheduler - the Scheduler to notify Observers on

• observeOn

   final Observable<T> observeOn(Scheduler scheduler, int bufferSize)

• observeOn

   final Observable<T> observeOn(Scheduler scheduler, boolean delayError, int bufferSize)

• lift

   final <R> Observable<R> lift(Observable.Operator<out R, out Object> operator)

• map

   final <R> Observable<R> map(Func1<out Object, out R> func)

• flatMap

   final <R> Observable<R> flatMap(Func1<out Object, out Observable<out R>> func)

• merge

   static <T> Observable<T> merge(Observable<out Observable<out T>> source)

• empty

   static <T> Observable<T> empty()

• just

   static <T> Observable<T> just(T value)

• just

   static <T> Observable<T> just(T t1, T t2)

• just

   static <T> Observable<T> just(T t1, T t2, T t3)

• just

   static <T> Observable<T> just(T t1, T t2, T t3, T t4)

• just

   static <T> Observable<T> just(T t1, T t2, T t3, T t4, T t5)

• from

   static <T> Observable<T> from(Array<T> array)

• from

   static <T> Observable<T> from(Iterable<out T> iterable)

• filter

   final Observable<T> filter(Func1<out Object, Boolean> predicate)

• onErrorResumeNext

   final Observable<T> onErrorResumeNext(Func1<out Object, out Observable<out T>> resumeFunction)

• error

   static <T> Observable<T> error(Throwable exception)

• doOnError

   final Observable<T> doOnError(Action1<out Object> onError)

• timeout

   final Observable<T> timeout(long timeout, TimeUnit timeUnit)

• timeout

   final Observable<T> timeout(long timeout, TimeUnit timeUnit, Observable<out T> other, Scheduler scheduler)

• debounce

   final <U> Observable<T> debounce(Func1<out Object, out Observable<U>> debounceSelector)

• toList

   final Observable<List<T>> toList()