@@ -8923,12 +8923,12 @@ public final Maybe<T> reduce(BiFunction<T, T, T> reducer) {
89238923 * the application of this operator via {@link #defer(Callable)}:
89248924 * <pre><code>
89258925 * ObservableSource<T> source = ...
8926- * ObservableSource .defer(() -> source.reduce(new ArrayList<>(), (list, item) -> list.add(item)));
8926+ * Observable .defer(() -> source.reduce(new ArrayList<>(), (list, item) -> list.add(item)));
89278927 *
89288928 * // alternatively, by using compose to stay fluent
89298929 *
89308930 * source.compose(o ->
8931- * ObservableSource .defer(() -> o.reduce(new ArrayList<>(), (list, item) -> list.add(item)))
8931+ * Observable .defer(() -> o.reduce(new ArrayList<>(), (list, item) -> list.add(item)))
89328932 * );
89338933 * </code></pre>
89348934 * <dl>
@@ -8972,12 +8972,12 @@ public final <R> Single<R> reduce(R seed, BiFunction<R, ? super T, R> reducer) {
89728972 * the application of this operator via {@link #defer(Callable)}:
89738973 * <pre><code>
89748974 * ObservableSource<T> source = ...
8975- * ObservableSource .defer(() -> source.reduce(new ArrayList<>(), (list, item) -> list.add(item)));
8975+ * Observable .defer(() -> source.reduce(new ArrayList<>(), (list, item) -> list.add(item)));
89768976 *
89778977 * // alternatively, by using compose to stay fluent
89788978 *
89798979 * source.compose(o ->
8980- * ObservableSource .defer(() -> o.reduce(new ArrayList<>(), (list, item) -> list.add(item)))
8980+ * Observable .defer(() -> o.reduce(new ArrayList<>(), (list, item) -> list.add(item)))
89818981 * );
89828982 * </code></pre>
89838983 * <dl>
@@ -10034,12 +10034,12 @@ public final Observable<T> scan(BiFunction<T, T, T> accumulator) {
1003410034 * the application of this operator via {@link #defer(Callable)}:
1003510035 * <pre><code>
1003610036 * ObservableSource<T> source = ...
10037- * ObservableSource .defer(() -> source.scan(new ArrayList<>(), (list, item) -> list.add(item)));
10037+ * Observable .defer(() -> source.scan(new ArrayList<>(), (list, item) -> list.add(item)));
1003810038 *
1003910039 * // alternatively, by using compose to stay fluent
1004010040 *
1004110041 * source.compose(o ->
10042- * ObservableSource .defer(() -> o.scan(new ArrayList<>(), (list, item) -> list.add(item)))
10042+ * Observable .defer(() -> o.scan(new ArrayList<>(), (list, item) -> list.add(item)))
1004310043 * );
1004410044 * </code></pre>
1004510045 * <dl>
@@ -10083,12 +10083,12 @@ public final <R> Observable<R> scan(final R initialValue, BiFunction<R, ? super
1008310083 * the application of this operator via {@link #defer(Callable)}:
1008410084 * <pre><code>
1008510085 * ObservableSource<T> source = ...
10086- * ObservableSource .defer(() -> source.scan(new ArrayList<>(), (list, item) -> list.add(item)));
10086+ * Observable .defer(() -> source.scan(new ArrayList<>(), (list, item) -> list.add(item)));
1008710087 *
1008810088 * // alternatively, by using compose to stay fluent
1008910089 *
1009010090 * source.compose(o ->
10091- * ObservableSource .defer(() -> o.scan(new ArrayList<>(), (list, item) -> list.add(item)))
10091+ * Observable .defer(() -> o.scan(new ArrayList<>(), (list, item) -> list.add(item)))
1009210092 * );
1009310093 * </code></pre>
1009410094 * <dl>
0 commit comments