84
84
* System.out.println("Done!");
85
85
* }
86
86
* });
87
- *
87
+ *
88
88
* Thread.sleep(500);
89
89
* // the sequence can now be disposed via dispose()
90
90
* d.dispose();
91
91
* </code></pre>
92
- *
92
+ *
93
93
* @param <T>
94
94
* the type of the items emitted by the Observable
95
95
* @see Flowable
@@ -1278,7 +1278,7 @@ public static <T> Observable<T> concat(
1278
1278
public static <T> Observable<T> concatArray(ObservableSource<? extends T>... sources) {
1279
1279
if (sources.length == 0) {
1280
1280
return empty();
1281
- } else
1281
+ }
1282
1282
if (sources.length == 1) {
1283
1283
return wrap((ObservableSource<T>)sources[0]);
1284
1284
}
@@ -1305,7 +1305,7 @@ public static <T> Observable<T> concatArray(ObservableSource<? extends T>... sou
1305
1305
public static <T> Observable<T> concatArrayDelayError(ObservableSource<? extends T>... sources) {
1306
1306
if (sources.length == 0) {
1307
1307
return empty();
1308
- } else
1308
+ }
1309
1309
if (sources.length == 1) {
1310
1310
return (Observable<T>)wrap(sources[0]);
1311
1311
}
@@ -1765,7 +1765,7 @@ public static <T> Observable<T> fromArray(T... items) {
1765
1765
ObjectHelper.requireNonNull(items, "items is null");
1766
1766
if (items.length == 0) {
1767
1767
return empty();
1768
- } else
1768
+ }
1769
1769
if (items.length == 1) {
1770
1770
return just(items[0]);
1771
1771
}
@@ -9626,7 +9626,7 @@ public final Single<T> lastOrError() {
9626
9626
* Example:
9627
9627
* <pre><code>
9628
9628
* // Step 1: Create the consumer type that will be returned by the ObservableOperator.apply():
9629
- *
9629
+ *
9630
9630
* public final class CustomObserver<T> implements Observer<T>, Disposable {
9631
9631
*
9632
9632
* // The downstream's Observer that will receive the onXXX events
@@ -12816,10 +12816,10 @@ public final Observable<T> take(long time, TimeUnit unit, Scheduler scheduler) {
12816
12816
public final Observable<T> takeLast(int count) {
12817
12817
if (count < 0) {
12818
12818
throw new IndexOutOfBoundsException("count >= 0 required but it was " + count);
12819
- } else
12819
+ }
12820
12820
if (count == 0) {
12821
12821
return RxJavaPlugins.onAssembly(new ObservableIgnoreElements<T>(this));
12822
- } else
12822
+ }
12823
12823
if (count == 1) {
12824
12824
return RxJavaPlugins.onAssembly(new ObservableTakeLastOne<T>(this));
12825
12825
}
0 commit comments