@@ -867,7 +867,7 @@ public static <T> Observable<T> merge(Single<? extends T> t1, Single<? extends T
867
867
* <dt><b>Scheduler:</b></dt>
868
868
* <dd>{@code merge} does not operate by default on a particular {@link Scheduler}.</dd>
869
869
* </dl>
870
- *
870
+ *
871
871
* @param t1
872
872
* a Single to be merged
873
873
* @param t2
@@ -902,7 +902,7 @@ public static <T> Observable<T> merge(Single<? extends T> t1, Single<? extends T
902
902
* <dt><b>Scheduler:</b></dt>
903
903
* <dd>{@code merge} does not operate by default on a particular {@link Scheduler}.</dd>
904
904
* </dl>
905
- *
905
+ *
906
906
* @param t1
907
907
* a Single to be merged
908
908
* @param t2
@@ -937,7 +937,7 @@ public static <T> Observable<T> merge(Single<? extends T> t1, Single<? extends T
937
937
* <dt><b>Scheduler:</b></dt>
938
938
* <dd>{@code zip} does not operate by default on a particular {@link Scheduler}.</dd>
939
939
* </dl>
940
- *
940
+ *
941
941
* @param s1
942
942
* the first source Single
943
943
* @param s2
@@ -966,7 +966,7 @@ public R call(Object... args) {
966
966
* <dt><b>Scheduler:</b></dt>
967
967
* <dd>{@code zip} does not operate by default on a particular {@link Scheduler}.</dd>
968
968
* </dl>
969
- *
969
+ *
970
970
* @param s1
971
971
* the first source Single
972
972
* @param s2
@@ -997,7 +997,7 @@ public R call(Object... args) {
997
997
* <dt><b>Scheduler:</b></dt>
998
998
* <dd>{@code zip} does not operate by default on a particular {@link Scheduler}.</dd>
999
999
* </dl>
1000
- *
1000
+ *
1001
1001
* @param s1
1002
1002
* the first source Single
1003
1003
* @param s2
@@ -1030,7 +1030,7 @@ public R call(Object... args) {
1030
1030
* <dt><b>Scheduler:</b></dt>
1031
1031
* <dd>{@code zip} does not operate by default on a particular {@link Scheduler}.</dd>
1032
1032
* </dl>
1033
- *
1033
+ *
1034
1034
* @param s1
1035
1035
* the first source Single
1036
1036
* @param s2
@@ -1065,7 +1065,7 @@ public R call(Object... args) {
1065
1065
* <dt><b>Scheduler:</b></dt>
1066
1066
* <dd>{@code zip} does not operate by default on a particular {@link Scheduler}.</dd>
1067
1067
* </dl>
1068
- *
1068
+ *
1069
1069
* @param s1
1070
1070
* the first source Single
1071
1071
* @param s2
@@ -1103,7 +1103,7 @@ public R call(Object... args) {
1103
1103
* <dt><b>Scheduler:</b></dt>
1104
1104
* <dd>{@code zip} does not operate by default on a particular {@link Scheduler}.</dd>
1105
1105
* </dl>
1106
- *
1106
+ *
1107
1107
* @param s1
1108
1108
* the first source Single
1109
1109
* @param s2
@@ -1143,7 +1143,7 @@ public R call(Object... args) {
1143
1143
* <dt><b>Scheduler:</b></dt>
1144
1144
* <dd>{@code zip} does not operate by default on a particular {@link Scheduler}.</dd>
1145
1145
* </dl>
1146
- *
1146
+ *
1147
1147
* @param s1
1148
1148
* the first source Single
1149
1149
* @param s2
@@ -1185,7 +1185,7 @@ public R call(Object... args) {
1185
1185
* <dt><b>Scheduler:</b></dt>
1186
1186
* <dd>{@code zip} does not operate by default on a particular {@link Scheduler}.</dd>
1187
1187
* </dl>
1188
- *
1188
+ *
1189
1189
* @param s1
1190
1190
* the first source Single
1191
1191
* @param s2
@@ -1253,7 +1253,7 @@ public static <R> Single<R> zip(Iterable<? extends Single<?>> singles, FuncN<? e
1253
1253
* <dt><b>Scheduler:</b></dt>
1254
1254
* <dd>{@code concat} does not operate by default on a particular {@link Scheduler}.</dd>
1255
1255
* </dl>
1256
- *
1256
+ *
1257
1257
* @param t1
1258
1258
* a Single to be concatenated after the current
1259
1259
* @return an Observable that emits the item emitted by the source Single, followed by the item emitted by
@@ -1273,7 +1273,7 @@ public final Observable<T> concatWith(Single<? extends T> t1) {
1273
1273
* <dt><b>Scheduler:</b></dt>
1274
1274
* <dd>{@code flatMap} does not operate by default on a particular {@link Scheduler}.</dd>
1275
1275
* </dl>
1276
- *
1276
+ *
1277
1277
* @param func
1278
1278
* a function that, when applied to the item emitted by the source Single, returns a Single
1279
1279
* @return the Single returned from {@code func} when applied to the item emitted by the source Single
@@ -1295,7 +1295,7 @@ public final <R> Single<R> flatMap(final Func1<? super T, ? extends Single<? ext
1295
1295
* <dt><b>Scheduler:</b></dt>
1296
1296
* <dd>{@code flatMapObservable} does not operate by default on a particular {@link Scheduler}.</dd>
1297
1297
* </dl>
1298
- *
1298
+ *
1299
1299
* @param func
1300
1300
* a function that, when applied to the item emitted by the source Single, returns an
1301
1301
* Observable
@@ -1336,7 +1336,7 @@ public final <R> Single<R> map(Func1<? super T, ? extends R> func) {
1336
1336
* <dt><b>Scheduler:</b></dt>
1337
1337
* <dd>{@code mergeWith} does not operate by default on a particular {@link Scheduler}.</dd>
1338
1338
* </dl>
1339
- *
1339
+ *
1340
1340
* @param t1
1341
1341
* a Single to be merged
1342
1342
* @return an Observable that emits all of the items emitted by the source Singles
@@ -1355,7 +1355,7 @@ public final Observable<T> mergeWith(Single<? extends T> t1) {
1355
1355
* <dt><b>Scheduler:</b></dt>
1356
1356
* <dd>you specify which {@link Scheduler} this operator will use</dd>
1357
1357
* </dl>
1358
- *
1358
+ *
1359
1359
* @param scheduler
1360
1360
* the {@link Scheduler} to notify subscribers on
1361
1361
* @return the source Single modified so that its subscribers are notified on the specified
@@ -1390,7 +1390,7 @@ public final Single<T> observeOn(Scheduler scheduler) {
1390
1390
* <dt><b>Scheduler:</b></dt>
1391
1391
* <dd>{@code onErrorReturn} does not operate by default on a particular {@link Scheduler}.</dd>
1392
1392
* </dl>
1393
- *
1393
+ *
1394
1394
* @param resumeFunction
1395
1395
* a function that returns an item that the new Single will emit if the source Single encounters
1396
1396
* an error
@@ -1438,7 +1438,7 @@ public final Single<T> onErrorResumeNext(Single<? extends T> resumeSingleInCaseO
1438
1438
* <dt><b>Scheduler:</b></dt>
1439
1439
* <dd>{@code subscribe} does not operate by default on a particular {@link Scheduler}.</dd>
1440
1440
* </dl>
1441
- *
1441
+ *
1442
1442
* @return a {@link Subscription} reference can request the {@link Single} stop work.
1443
1443
* @throws OnErrorNotImplementedException
1444
1444
* if the Single tries to call {@link Subscriber#onError}
@@ -1471,7 +1471,7 @@ public final void onNext(T args) {
1471
1471
* <dt><b>Scheduler:</b></dt>
1472
1472
* <dd>{@code subscribe} does not operate by default on a particular {@link Scheduler}.</dd>
1473
1473
* </dl>
1474
- *
1474
+ *
1475
1475
* @param onSuccess
1476
1476
* the {@code Action1<T>} you have designed to accept the emission from the Single
1477
1477
* @return a {@link Subscription} reference can request the {@link Single} stop work.
@@ -1513,7 +1513,7 @@ public final void onNext(T args) {
1513
1513
* <dt><b>Scheduler:</b></dt>
1514
1514
* <dd>{@code subscribe} does not operate by default on a particular {@link Scheduler}.</dd>
1515
1515
* </dl>
1516
- *
1516
+ *
1517
1517
* @param onSuccess
1518
1518
* the {@code Action1<T>} you have designed to accept the emission from the Single
1519
1519
* @param onError
@@ -1563,7 +1563,7 @@ public final void onNext(T args) {
1563
1563
* <dt><b>Scheduler:</b></dt>
1564
1564
* <dd>{@code unsafeSubscribe} does not operate by default on a particular {@link Scheduler}.</dd>
1565
1565
* </dl>
1566
- *
1566
+ *
1567
1567
* @param subscriber
1568
1568
* the Subscriber that will handle the emission or notification from the Single
1569
1569
*/
@@ -1615,7 +1615,7 @@ public final void unsafeSubscribe(Subscriber<? super T> subscriber) {
1615
1615
* <dt><b>Scheduler:</b></dt>
1616
1616
* <dd>{@code subscribe} does not operate by default on a particular {@link Scheduler}.</dd>
1617
1617
* </dl>
1618
- *
1618
+ *
1619
1619
* @param subscriber
1620
1620
* the {@link Subscriber} that will handle the emission or notification from the Single
1621
1621
* @return a {@link Subscription} reference can request the {@link Single} stop work.
@@ -1703,7 +1703,7 @@ public final Subscription subscribe(Subscriber<? super T> subscriber) {
1703
1703
* <dt><b>Scheduler:</b></dt>
1704
1704
* <dd>{@code subscribe} does not operate by default on a particular {@link Scheduler}.</dd>
1705
1705
* </dl>
1706
- *
1706
+ *
1707
1707
* @param te
1708
1708
* the {@link SingleSubscriber} that will handle the emission or notification from the Single
1709
1709
* @return a {@link Subscription} reference can request the {@link Single} stop work.
@@ -1749,7 +1749,7 @@ public void onNext(T t) {
1749
1749
* <dt><b>Scheduler:</b></dt>
1750
1750
* <dd>you specify which {@link Scheduler} this operator will use</dd>
1751
1751
* </dl>
1752
- *
1752
+ *
1753
1753
* @param scheduler
1754
1754
* the {@link Scheduler} to perform subscription actions on
1755
1755
* @return the source Single modified so that its subscriptions happen on the specified {@link Scheduler}
@@ -1798,12 +1798,12 @@ public void onError(Throwable error) {
1798
1798
}
1799
1799
});
1800
1800
}
1801
-
1801
+
1802
1802
/**
1803
1803
* Converts this Single into an {@link Observable}.
1804
1804
* <p>
1805
1805
* <img width="640" height="305" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Single.toObservable.png" alt="">
1806
- *
1806
+ *
1807
1807
* @return an {@link Observable} that emits a single item T.
1808
1808
*/
1809
1809
public final Observable <T > toObservable () {
@@ -1820,7 +1820,7 @@ public final Observable<T> toObservable() {
1820
1820
* <dt><b>Scheduler:</b></dt>
1821
1821
* <dd>This version of {@code timeout} operates by default on the {@code computation} {@link Scheduler}.</dd>
1822
1822
* </dl>
1823
- *
1823
+ *
1824
1824
* @param timeout
1825
1825
* maximum duration before the Single times out
1826
1826
* @param timeUnit
@@ -1843,7 +1843,7 @@ public final Single<T> timeout(long timeout, TimeUnit timeUnit) {
1843
1843
* <dt><b>Scheduler:</b></dt>
1844
1844
* <dd>you specify which {@link Scheduler} this operator will use</dd>
1845
1845
* </dl>
1846
- *
1846
+ *
1847
1847
* @param timeout
1848
1848
* maximum duration before the Single times out
1849
1849
* @param timeUnit
@@ -1868,7 +1868,7 @@ public final Single<T> timeout(long timeout, TimeUnit timeUnit, Scheduler schedu
1868
1868
* <dt><b>Scheduler:</b></dt>
1869
1869
* <dd>This version of {@code timeout} operates by default on the {@code computation} {@link Scheduler}.</dd>
1870
1870
* </dl>
1871
- *
1871
+ *
1872
1872
* @param timeout
1873
1873
* maximum time before a timeout occurs
1874
1874
* @param timeUnit
@@ -1892,7 +1892,7 @@ public final Single<T> timeout(long timeout, TimeUnit timeUnit, Single<? extends
1892
1892
* <dt><b>Scheduler:</b></dt>
1893
1893
* <dd>you specify which {@link Scheduler} this operator will use</dd>
1894
1894
* </dl>
1895
- *
1895
+ *
1896
1896
* @param timeout
1897
1897
* maximum duration before a timeout occurs
1898
1898
* @param timeUnit
@@ -1935,7 +1935,7 @@ public final BlockingSingle<T> toBlocking() {
1935
1935
* <dt><b>Scheduler:</b></dt>
1936
1936
* <dd>{@code zipWith} does not operate by default on a particular {@link Scheduler}.</dd>
1937
1937
* </dl>
1938
- *
1938
+ *
1939
1939
* @param <T2>
1940
1940
* the type of items emitted by the {@code other} Single
1941
1941
* @param <R>
@@ -1989,7 +1989,7 @@ public void onNext(T t) {
1989
1989
1990
1990
return lift (new OperatorDoOnEach <T >(observer ));
1991
1991
}
1992
-
1992
+
1993
1993
/**
1994
1994
* Modifies the source {@link Single} so that it invokes an action when it calls {@code onSuccess}.
1995
1995
* <p>
0 commit comments