diff --git a/src/main/java/io/reactivex/Observable.java b/src/main/java/io/reactivex/Observable.java index c74ab3f7d4..a3f204206b 100644 --- a/src/main/java/io/reactivex/Observable.java +++ b/src/main/java/io/reactivex/Observable.java @@ -9414,7 +9414,7 @@ public final Single lastOrError() { * @Override * public void onSubscribe(Disposable s) { * if (upstream != null) { - * s.cancel(); + * s.dispose(); * } else { * upstream = s; * downstream.onSubscribe(this); @@ -9473,10 +9473,10 @@ public final Single lastOrError() { * // Such class may define additional parameters to be submitted to * // the custom consumer type. * - * final class CustomOperator<T> implements ObservableOperator<String> { + * final class CustomOperator<T> implements ObservableOperator<String, T> { * @Override - * public Observer<? super String> apply(Observer<? super T> upstream) { - * return new CustomObserver<T>(upstream); + * public Observer<T> apply(Observer<? super String> downstream) { + * return new CustomObserver<T>(downstream); * } * } *