diff --git a/src/main/java/io/reactivex/subscribers/DefaultSubscriber.java b/src/main/java/io/reactivex/subscribers/DefaultSubscriber.java index dbd27242d7..7b34ab9adc 100644 --- a/src/main/java/io/reactivex/subscribers/DefaultSubscriber.java +++ b/src/main/java/io/reactivex/subscribers/DefaultSubscriber.java @@ -50,9 +50,8 @@ * @param the value type * *

Example

- * Disposable d =
- *     Flowable.range(1, 5)
- *     .subscribeWith(new DefaultSubscriber<Integer>() {
+ * Flowable.range(1, 5)
+ *     .subscribe(new DefaultSubscriber<Integer>() {
  *         @Override public void onStart() {
  *             System.out.println("Start!");
  *             request(1);
@@ -71,8 +70,6 @@
  *             System.out.println("Done!");
  *         }
  *     });
- * // ...
- * d.dispose();
  * 
*/ public abstract class DefaultSubscriber implements FlowableSubscriber {