We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c11f715 commit b17bd1aCopy full SHA for b17bd1a
src/main/java/io/reactivex/subscribers/DefaultSubscriber.java
@@ -50,9 +50,8 @@
50
* @param <T> the value type
51
*
52
* <p>Example<code><pre>
53
- * Disposable d =
54
- * Flowable.range(1, 5)
55
- * .subscribeWith(new DefaultSubscriber<Integer>() {
+ * Flowable.range(1, 5)
+ * .subscribe(new DefaultSubscriber<Integer>() {
56
* @Override public void onStart() {
57
* System.out.println("Start!");
58
* request(1);
@@ -71,8 +70,6 @@
71
70
* System.out.println("Done!");
72
* }
73
* });
74
- * // ...
75
- * d.dispose();
76
* </pre></code>
77
*/
78
public abstract class DefaultSubscriber<T> implements FlowableSubscriber<T> {
0 commit comments