File tree Expand file tree Collapse file tree 4 files changed +4
-8
lines changed
rxjava-core/src/main/java/rx Expand file tree Collapse file tree 4 files changed +4
-8
lines changed Original file line number Diff line number Diff line change @@ -781,13 +781,11 @@ public static <T> Observable<T> switchDo(Observable<Observable<T>> sequenceOfSeq
781
781
}
782
782
783
783
/**
784
- * Given an Observable that emits Observables, creates a single Observable that
784
+ * On an Observable that emits Observables, creates a single Observable that
785
785
* emits the items emitted by the most recently published of those Observables.
786
786
* <p>
787
787
* <img width="640" src="https://github.com/Netflix/RxJava/wiki/images/rx-operators/switchDo.png">
788
788
*
789
- * @param sequenceOfSequences
790
- * the source Observable that emits Observables
791
789
* @return an Observable that emits only the items emitted by the most recently published
792
790
* Observable
793
791
* @throws ClassCastException
@@ -1133,7 +1131,7 @@ public Observable<List<T>> buffer(int count) {
1133
1131
* The maximum size of each buffer before it should be emitted.
1134
1132
* @param skip
1135
1133
* How many produced values need to be skipped before starting a new buffer. Note that when "skip" and
1136
- * "count" are equals that this is the same operation as {@link Observable#buffer(Observable, int)}.
1134
+ * "count" are equals that this is the same operation as {@link Observable#buffer(int)}.
1137
1135
* @return
1138
1136
* An {@link Observable} which produces buffers every "skipped" values containing at most
1139
1137
* "count" produced values.
Original file line number Diff line number Diff line change 20
20
/**
21
21
* Subscription returns from {@link Observable#subscribe(Observer)} to allow unsubscribing.
22
22
* <p>
23
- * See utilities in {@link Subscriptions} and implementations in the {@link rx.subscriptions} package.
23
+ * See utilities in {@link Subscriptions} and implementations in the {@code rx.subscriptions} package.
24
24
* <p>
25
25
* This interface is the RxJava equivalent of {@code IDisposable} in Microsoft's Rx implementation.
26
26
*/
Original file line number Diff line number Diff line change 24
24
* An {@link Observable} that has been grouped by a key whose value can be obtained using
25
25
* {@link #getKey()} <p>
26
26
*
27
- * @see Observable#groupBy(Observable, Func1)
27
+ * @see Observable#groupBy(Func1)
28
28
*
29
29
* @param <K> the type of the key
30
30
* @param <T> the type of the elements in the group
Original file line number Diff line number Diff line change @@ -43,8 +43,6 @@ public class OperationToIterator {
43
43
/**
44
44
* Returns an iterator that iterates all values of the observable.
45
45
*
46
- * @param that
47
- * an observable sequence to get an iterator for.
48
46
* @param <T>
49
47
* the type of source.
50
48
* @return the iterator that could be used to iterate over the elements of the observable.
You can’t perform that action at this time.
0 commit comments