From 7b58fe89c0eb53466cea020571fdd0692be950ae Mon Sep 17 00:00:00 2001 From: Volker Leck Date: Sun, 11 Jun 2017 16:40:18 +0100 Subject: [PATCH 1/2] change sample such that it compiles --- src/main/java/io/reactivex/subscribers/DefaultSubscriber.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/src/main/java/io/reactivex/subscribers/DefaultSubscriber.java b/src/main/java/io/reactivex/subscribers/DefaultSubscriber.java index dbd27242d7..87984516fb 100644 --- a/src/main/java/io/reactivex/subscribers/DefaultSubscriber.java +++ b/src/main/java/io/reactivex/subscribers/DefaultSubscriber.java @@ -52,7 +52,7 @@ *

Example

  * Disposable d =
  *     Flowable.range(1, 5)
- *     .subscribeWith(new DefaultSubscriber<Integer>() {
+ *     .subscribe(new DefaultSubscriber<Integer>() {
  *         @Override public void onStart() {
  *             System.out.println("Start!");
  *             request(1);
@@ -71,8 +71,6 @@
  *             System.out.println("Done!");
  *         }
  *     });
- * // ...
- * d.dispose();
  * 
*/ public abstract class DefaultSubscriber implements FlowableSubscriber { From f0e70bcc223924e474e7dfc93990ae713af4fa16 Mon Sep 17 00:00:00 2001 From: Volker Leck Date: Sun, 11 Jun 2017 16:50:43 +0100 Subject: [PATCH 2/2] fix: remove assignment --- src/main/java/io/reactivex/subscribers/DefaultSubscriber.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/src/main/java/io/reactivex/subscribers/DefaultSubscriber.java b/src/main/java/io/reactivex/subscribers/DefaultSubscriber.java index 87984516fb..7b34ab9adc 100644 --- a/src/main/java/io/reactivex/subscribers/DefaultSubscriber.java +++ b/src/main/java/io/reactivex/subscribers/DefaultSubscriber.java @@ -50,8 +50,7 @@ * @param the value type * *

Example

- * Disposable d =
- *     Flowable.range(1, 5)
+ * Flowable.range(1, 5)
  *     .subscribe(new DefaultSubscriber<Integer>() {
  *         @Override public void onStart() {
  *             System.out.println("Start!");