From 1a94de58f9d6e203b12a5003733ce05183b800c9 Mon Sep 17 00:00:00 2001 From: Chuanyi Li Date: Sun, 22 Jul 2018 17:16:29 +0800 Subject: [PATCH] Fixing javadoc's code example of Observable#lift. --- src/main/java/io/reactivex/Observable.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) 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); * } * } *