@@ -144,6 +144,7 @@ public static interface OnSubscribeFunc<T> extends Function {
144
144
* @param lift
145
145
* @return an Observable that emits values that are the result of applying the bind function to the values
146
146
* of the current Observable
147
+ * @since 0.17
147
148
*/
148
149
public final <R > Observable <R > lift (final Operator <? extends R , ? super T > lift ) {
149
150
return new Observable <R >(new OnSubscribe <R >() {
@@ -2154,6 +2155,7 @@ public final static <T> Observable<T> mergeDelayError(Observable<? extends T> t1
2154
2155
* <img width="640" src="https://raw.github.com/wiki/Netflix/RxJava/images/rx-operators/nest.png">
2155
2156
*
2156
2157
* @return an Observable that emits a single item: the source Observable
2158
+ * @since 0.17
2157
2159
*/
2158
2160
public final Observable <Observable <T >> nest () {
2159
2161
return just (this );
@@ -2247,6 +2249,7 @@ public final static <T> Observable<Observable<T>> parallelMerge(Observable<Obser
2247
2249
*
2248
2250
* @param groups
2249
2251
* @return an Observable containing a stream of nested GroupedObservables with swapped inner-outer keys.
2252
+ * @since 0.17
2250
2253
*/
2251
2254
public static final <K1 , K2 , T > Observable <GroupedObservable <K2 , GroupedObservable <K1 , T >>> pivot (Observable <GroupedObservable <K1 , GroupedObservable <K2 , T >>> groups ) {
2252
2255
return groups .lift (new OperatorPivot <K1 , K2 , T >());
@@ -3699,6 +3702,7 @@ public final void onNext(T args) {
3699
3702
* @return the source Observable with the side-effecting behavior applied
3700
3703
* @see <a href="https://github.com/Netflix/RxJava/wiki/Observable-Utility-Operators#wiki-doonterminate">RxJava Wiki: doOnTerminate()</a>
3701
3704
* @see <a href="http://msdn.microsoft.com/en-us/library/hh229804.aspx">MSDN: Observable.Do</a>
3705
+ * @since 0.17
3702
3706
*/
3703
3707
public final Observable <T > doOnTerminate (final Action0 onTerminate ) {
3704
3708
Observer <T > observer = new Observer <T >() {
@@ -4439,6 +4443,7 @@ public final Observable<T> onErrorReturn(Func1<Throwable, ? extends T> resumeFun
4439
4443
* of the error
4440
4444
* @return the original Observable, with appropriately modified behavior
4441
4445
* @see <a href="https://github.com/Netflix/RxJava/wiki/Error-Handling-Operators#onerrorflatmap">RxJava Wiki: onErrorFlatMap()</a>
4446
+ * @since 0.17
4442
4447
*/
4443
4448
public final Observable <T > onErrorFlatMap (final Func1 <OnErrorThrowable , ? extends Observable <? extends T >> resumeFunction ) {
4444
4449
return lift (new OperatorOnErrorFlatMap <T >(resumeFunction ));
@@ -4724,6 +4729,7 @@ public final Observable<T> repeat(Scheduler scheduler) {
4724
4729
* if {@code count} is less than zero
4725
4730
* @see <a href="https://github.com/Netflix/RxJava/wiki/Creating-Observables#wiki-repeat">RxJava Wiki: repeat()</a>
4726
4731
* @see <a href="http://msdn.microsoft.com/en-us/library/hh229428.aspx">MSDN: Observable.Repeat</a>
4732
+ * @since 0.17
4727
4733
*/
4728
4734
public final Observable <T > repeat (long count ) {
4729
4735
if (count < 0 ) {
@@ -4745,6 +4751,7 @@ public final Observable<T> repeat(long count) {
4745
4751
* @return an Observable that repeats the sequence of items emitted by the source Observable at most {@code count} times on a particular Scheduler
4746
4752
* @see <a href="https://github.com/Netflix/RxJava/wiki/Creating-Observables#wiki-repeat">RxJava Wiki: repeat()</a>
4747
4753
* @see <a href="http://msdn.microsoft.com/en-us/library/hh229428.aspx">MSDN: Observable.Repeat</a>
4754
+ * @since 0.17
4748
4755
*/
4749
4756
public final Observable <T > repeat (long count , Scheduler scheduler ) {
4750
4757
return nest ().lift (new OperatorRepeat <T >(count , scheduler ));
@@ -5310,6 +5317,9 @@ public final <R> Observable<R> scan(R initialValue, Func2<R, ? super T, R> accum
5310
5317
return lift (new OperatorScan <R , T >(initialValue , accumulator ));
5311
5318
}
5312
5319
5320
+ /*
5321
+ * @since 0.17
5322
+ */
5313
5323
public final Observable <T > serialize () {
5314
5324
return lift (new OperatorSerialize <T >());
5315
5325
}
@@ -6127,6 +6137,7 @@ public void onNext(T t) {
6127
6137
*
6128
6138
* @param subscriber
6129
6139
* @return Subscription which is the Subscriber passed in
6140
+ * @since 0.17
6130
6141
*/
6131
6142
public final Subscription unsafeSubscribe (Subscriber <? super T > subscriber ) {
6132
6143
try {
@@ -7237,6 +7248,7 @@ public final Observable<List<T>> toSortedList(Func2<? super T, ? super T, Intege
7237
7248
* @param scheduler
7238
7249
* the {@link Scheduler} to perform subscription and unsubscription actions on
7239
7250
* @return the source Observable modified so that its unsubscriptions happen on the specified {@link Scheduler}
7251
+ * @since 0.17
7240
7252
*/
7241
7253
public final Observable <T > unsubscribeOn (Scheduler scheduler ) {
7242
7254
return lift (new OperatorUnsubscribeOn <T >(scheduler ));
0 commit comments