Skip to content

Commit bb1e313

Browse files
dimsuzakarnokd
authored andcommitted
2.x: Fix subscribeWith documentation examples (ReactiveX#5647)
1 parent 748fb50 commit bb1e313

File tree

4 files changed

+10
-10
lines changed

4 files changed

+10
-10
lines changed

src/main/java/io/reactivex/Completable.java

+3-3
Original file line numberDiff line numberDiff line change
@@ -1686,11 +1686,11 @@ public final void subscribe(CompletableObserver s) {
16861686
* Completable source = Completable.complete().delay(1, TimeUnit.SECONDS);
16871687
* CompositeDisposable composite = new CompositeDisposable();
16881688
*
1689-
* class ResourceCompletableObserver implements CompletableObserver, Disposable {
1689+
* DisposableCompletableObserver ds = new DisposableCompletableObserver() {
16901690
* // ...
1691-
* }
1691+
* };
16921692
*
1693-
* composite.add(source.subscribeWith(new ResourceCompletableObserver()));
1693+
* composite.add(source.subscribeWith(ds));
16941694
* </code></pre>
16951695
* <dl>
16961696
* <dt><b>Scheduler:</b></dt>

src/main/java/io/reactivex/Maybe.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -3772,11 +3772,11 @@ public final Maybe<T> subscribeOn(Scheduler scheduler) {
37723772
* Maybe&lt;Integer&gt; source = Maybe.just(1);
37733773
* CompositeDisposable composite = new CompositeDisposable();
37743774
*
3775-
* MaybeObserver&lt;Integer&gt; ms = new MaybeObserver&lt;&gt;() {
3775+
* DisposableMaybeObserver&lt;Integer&gt; ds = new DisposableMaybeObserver&lt;&gt;() {
37763776
* // ...
37773777
* };
37783778
*
3779-
* composite.add(source.subscribeWith(ms));
3779+
* composite.add(source.subscribeWith(ds));
37803780
* </code></pre>
37813781
* <dl>
37823782
* <dt><b>Scheduler:</b></dt>

src/main/java/io/reactivex/Observable.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -10939,11 +10939,11 @@ public final void subscribe(Observer<? super T> observer) {
1093910939
* Observable&lt;Integer&gt; source = Observable.range(1, 10);
1094010940
* CompositeDisposable composite = new CompositeDisposable();
1094110941
*
10942-
* ResourceObserver&lt;Integer&gt; rs = new ResourceObserver&lt;&gt;() {
10942+
* DisposableObserver&lt;Integer&gt; ds = new DisposableObserver&lt;&gt;() {
1094310943
* // ...
1094410944
* };
1094510945
*
10946-
* composite.add(source.subscribeWith(rs));
10946+
* composite.add(source.subscribeWith(ds));
1094710947
* </code></pre>
1094810948
* <dl>
1094910949
* <dt><b>Scheduler:</b></dt>

src/main/java/io/reactivex/Single.java

+3-3
Original file line numberDiff line numberDiff line change
@@ -2801,11 +2801,11 @@ public final void subscribe(SingleObserver<? super T> subscriber) {
28012801
* Single&lt;Integer&gt; source = Single.just(1);
28022802
* CompositeDisposable composite = new CompositeDisposable();
28032803
*
2804-
* class ResourceSingleObserver implements SingleObserver&lt;Integer&gt;, Disposable {
2804+
* DisposableSingleObserver&lt;Integer&gt; ds = new DisposableSingleObserver&lt;&gt;() {
28052805
* // ...
2806-
* }
2806+
* };
28072807
*
2808-
* composite.add(source.subscribeWith(new ResourceSingleObserver()));
2808+
* composite.add(source.subscribeWith(ds));
28092809
* </code></pre>
28102810
* <dl>
28112811
* <dt><b>Scheduler:</b></dt>

0 commit comments

Comments
 (0)