1.2 preparation cleanup and Experimental/Beta/Deprecated adjustments

[akarnokd]

This PR contains some cleanup, javadoc fixes as well as the API changes for 1.2:

Promote beta to standard

• rx.Observable.create(SyncOnSubscribe<S, T>)
• rx.Observable.doOnRequest(Action1<Long>)
• rx.Observable.flatMap(Func1<? super T, ? extends Observable<? extends R>>, Func1<? super Throwable, ? extends Observable<? extends R>>, Func0<? extends Observable<? extends R>>, int)
• rx.Observable.flatMap(Func1<? super T, ? extends Observable<? extends R>>, int)
• rx.Observable.flatMap(Func1<? super T, ? extends Observable<? extends U>>, Func2<? super T, ? super U, ? extends R>, int)
• rx.Observable.flatMapIterable(Func1<? super T, ? extends Iterable<? extends R>>, int)
• rx.Observable.flatMapIterable(Func1<? super T, ? extends Iterable<? extends U>>, Func2<? super T, ? super U, ? extends R>, int)
• rx.Observable.fromCallable(Callable<? extends T>)
• rx.Observable.toSingle()
• _ _
• rx.Single.fromCallable(Callable<? extends T>)
• _ _
• rx.SingleSubscriber<T>
• _ _
• rx.observables.ConnectableObservable.autoConnect()
• rx.observables.ConnectableObservable.autoConnect(int, Action1<? super Subscription>)
• rx.observables.ConnectableObservable.autoConnect(int)
• _ _
• rx.observables.SyncOnSubscribe<S, T>
• _ _
• rx.subjects.AsyncSubject.getThrowable()
• rx.subjects.AsyncSubject.getValue()
• rx.subjects.AsyncSubject.hasCompleted()
• rx.subjects.AsyncSubject.hasThrowable()
• rx.subjects.AsyncSubject.hasValue()
• _ _
• rx.subjects.BehaviorSubject.getThrowable()
• rx.subjects.BehaviorSubject.getValue()
• rx.subjects.BehaviorSubject.getValues()
• rx.subjects.BehaviorSubject.getValues(T[])
• rx.subjects.BehaviorSubject.hasCompleted()
• rx.subjects.BehaviorSubject.hasThrowable()
• rx.subjects.BehaviorSubject.hasValue()
• _ _
• rx.subjects.PublishSubject.getThrowable()
• rx.subjects.PublishSubject.hasCompleted()
• rx.subjects.PublishSubject.hasThrowable()
• _ _
• rx.subjects.ReplaySubject.getThrowable()
• rx.subjects.ReplaySubject.getValue()
• rx.subjects.ReplaySubject.getValues()
• rx.subjects.ReplaySubject.getValues(T[])
• rx.subjects.ReplaySubject.hasAnyValue()
• rx.subjects.ReplaySubject.hasCompleted()
• rx.subjects.ReplaySubject.hasThrowable()
• rx.subjects.ReplaySubject.hasValue()
• rx.subjects.ReplaySubject.size()

Promote experimental to standard

None.

Promote to beta

• rx.BackpressureOverflow
• rx.Observable.concatDelayError(Iterable<? extends Observable<? extends T>>)
• rx.Observable.concatDelayError(Observable<? extends Observable<? extends T>>)
• rx.Observable.concatEager(Iterable<? extends Observable<? extends T>>, int)
• rx.Observable.concatEager(Iterable<? extends Observable<? extends T>>)
• rx.Observable.concatEager(Observable<? extends Observable<? extends T>>, int)
• rx.Observable.concatEager(Observable<? extends Observable<? extends T>>)
• rx.Observable.concatEager(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>)
• rx.Observable.concatEager(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>)
• rx.Observable.concatEager(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>)
• rx.Observable.concatEager(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>)
• rx.Observable.concatEager(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>)
• rx.Observable.concatEager(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>)
• rx.Observable.concatEager(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>)
• rx.Observable.concatEager(Observable<? extends T>, Observable<? extends T>)
• rx.Observable.concatMapDelayError(Func1<? super T, ? extends Observable<? extends R>>)
• rx.Observable.concatMapEager(Func1<? super T, ? extends Observable<? extends R>>, int, int)
• rx.Observable.concatMapEager(Func1<? super T, ? extends Observable<? extends R>>, int)
• rx.Observable.concatMapEager(Func1<? super T, ? extends Observable<? extends R>>)
• rx.Observable.delaySubscription(Observable<U>)
• rx.Observable.distinctUntilChanged(Func2<? super T, ? super T, Boolean>)
• rx.Observable.mergeDelayError(Observable<? extends Observable<? extends T>>, int)
• rx.Observable.onBackpressureBuffer(long, Action0, Strategy)
• rx.Observable.switchMapDelayError(Func1<? super T, ? extends Observable<? extends R>>)
• rx.Observable.switchOnNextDelayError(Observable<? extends Observable<? extends T>>)
• rx.Observable.toCompletable()
• rx.Observable.toSortedList(Func2<? super T, ? super T, Integer>, int)
• rx.Observable.toSortedList(int)
• rx.Observable.using(Func0<Resource>, Func1<? super Resource, ? extends Observable<? extends T>>, Action1<? super Resource>, boolean)
• _ _
• rx.observables.BlockingObservable.subscribe()
• rx.observables.BlockingObservable.subscribe(Action1<? super T>, Action1<? super Throwable>, Action0)
• rx.observables.BlockingObservable.subscribe(Action1<? super T>, Action1<? super Throwable>)
• rx.observables.BlockingObservable.subscribe(Action1<? super T>)
• rx.observables.BlockingObservable.subscribe(Observer<? super T>)
• rx.observables.BlockingObservable.subscribe(Subscriber<? super T>)
• _ _
• rx.Completable
• _ _
• rx.Single.defer(Callable<Single<T>>)
• rx.Single.delay(long, TimeUnit, Scheduler)
• rx.Single.delay(long, TimeUnit)
• rx.Single.delaySubscription(Observable<?>)
• rx.Single.doAfterTerminate(Action0)
• rx.Single.doOnError(Action1<Throwable>)
• rx.Single.doOnSubscribe(Action0)
• rx.Single.doOnSuccess(Action1<? super T>)
• rx.Single.doOnUnsubscribe(Action0)
• rx.Single.lift(Operator<? extends R, ? super T>)
• rx.Single.onErrorResumeNext(Func1<Throwable, ? extends Single<? extends T>>)
• rx.Single.onErrorResumeNext(Single<? extends T>)
• rx.Single.toBlocking()
• rx.Single.toCompletable()
• rx.Single.using(Func0<Resource>, Func1<? super Resource, ? extends Single<? extends T>>, Action1<? super Resource>, boolean)
• rx.Single.using(Func0<Resource>, Func1<? super Resource, ? extends Single<? extends T>>, Action1<? super Resource>)
• _ _
• rx.exceptions.CompositeException.CompositeException(Throwable...)
• _ _
• rx.exceptions.Exceptions.throwOrReport(Throwable, Observer<?>, Object)
• rx.exceptions.Exceptions.throwOrReport(Throwable, Observer<?>)
• rx.exceptions.Exceptions.throwOrReport(Throwable, SingleSubscriber<?>)
• _ _
• `rx.singles.BlockingSingle``

Removed

• rx.Observable.extend(Func1<OnSubscribe<T>, R>)
• rx.Observable.fromAsync()
• _ _
• rx.Completable.CompletableSubscriber
• rx.Completable.CompletableOnSubscribe
• rx.Completable.CompletableLift
• rx.Completable.CompletableTransform

[codecov-io]

Current coverage is 84.52% (diff: 90.84%)

Merging #4549 into 1.x will increase coverage by 0.29%

@@                1.x      #4549   diff @@
==========================================
  Files           272        272          
  Lines         17647      17571    -76   
  Methods           0          0          
  Messages          0          0          
  Branches       2687       2683     -4   
==========================================
- Hits          14865      14852    -13   
+ Misses         1920       1866    -54   
+ Partials        862        853     -9   

Powered by Codecov. Last update ff16f76...a4e5562

[JakeWharton]

Needs a @since

[JakeWharton]

Oops nevermind. The whole class is since 1.2.

[JakeWharton]

👍