Skip to content

Commit ca10283

Browse files
MauinMauin
committed
rename Observable/Single #doOnCancel to #doOnDispose
1 parent 52dc050 commit ca10283

17 files changed

+59
-59
lines changed

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

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -6297,14 +6297,14 @@ public final Observable<T> doAfterTerminate(Action onFinally) {
62976297
* <dd>{@code doOnUnsubscribe} does not operate by default on a particular {@link Scheduler}.</dd>
62986298
* </dl>
62996299
*
6300-
* @param onCancel
6300+
* @param onDispose
63016301
* the action that gets called when the source {@code ObservableSource}'s Subscription is cancelled
63026302
* @return the source {@code ObservableSource} modified so as to call this Action when appropriate
63036303
* @see <a href="http://reactivex.io/documentation/operators/do.html">ReactiveX operators documentation: Do</a>
63046304
*/
63056305
@SchedulerSupport(SchedulerSupport.NONE)
6306-
public final Observable<T> doOnCancel(Action onCancel) {
6307-
return doOnLifecycle(Functions.emptyConsumer(), onCancel);
6306+
public final Observable<T> doOnDispose(Action onDispose) {
6307+
return doOnLifecycle(Functions.emptyConsumer(), onDispose);
63086308
}
63096309

63106310
/**
@@ -6437,16 +6437,16 @@ public final Observable<T> doOnError(Consumer<? super Throwable> onError) {
64376437
*
64386438
* @param onSubscribe
64396439
* a Consumer called with the Subscription sent via Subscriber.onSubscribe()
6440-
* @param onCancel
6441-
* called when the downstream cancels the Subscription via cancel()
6440+
* @param onDispose
6441+
* called when the downstream disposes the Subscription via dispose()
64426442
* @return the source ObservableSource with the side-effecting behavior applied
64436443
* @see <a href="http://reactivex.io/documentation/operators/do.html">ReactiveX operators documentation: Do</a>
64446444
*/
64456445
@SchedulerSupport(SchedulerSupport.NONE)
6446-
public final Observable<T> doOnLifecycle(final Consumer<? super Disposable> onSubscribe, final Action onCancel) {
6446+
public final Observable<T> doOnLifecycle(final Consumer<? super Disposable> onSubscribe, final Action onDispose) {
64476447
ObjectHelper.requireNonNull(onSubscribe, "onSubscribe is null");
6448-
ObjectHelper.requireNonNull(onCancel, "onCancel is null");
6449-
return RxJavaPlugins.onAssembly(new ObservableDoOnLifecycle<T>(this, onSubscribe, onCancel));
6448+
ObjectHelper.requireNonNull(onDispose, "onDispose is null");
6449+
return RxJavaPlugins.onAssembly(new ObservableDoOnLifecycle<T>(this, onSubscribe, onDispose));
64506450
}
64516451

64526452
/**

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1579,13 +1579,13 @@ public final Single<T> doOnError(final Consumer<? super Throwable> onError) {
15791579
* <dt><b>Scheduler:</b></dt>
15801580
* <dd>{@code doOnSubscribe} does not operate by default on a particular {@link Scheduler}.</dd>
15811581
* </dl>
1582-
* @param onCancel the runnable called when the subscription is cancelled (disposed)
1582+
* @param onDispose the runnable called when the subscription is disposed
15831583
* @return the new Single instance
15841584
* @since 2.0
15851585
*/
1586-
public final Single<T> doOnCancel(final Action onCancel) {
1587-
ObjectHelper.requireNonNull(onCancel, "onCancel is null");
1588-
return RxJavaPlugins.onAssembly(new SingleDoOnCancel<T>(this, onCancel));
1586+
public final Single<T> doOnDispose(final Action onDispose) {
1587+
ObjectHelper.requireNonNull(onDispose, "onDispose is null");
1588+
return RxJavaPlugins.onAssembly(new SingleDoOnDispose<T>(this, onDispose));
15891589
}
15901590

15911591
/**

‎src/main/java/io/reactivex/internal/operators/observable/ObservableDoOnLifecycle.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -19,17 +19,17 @@
1919

2020
public final class ObservableDoOnLifecycle<T> extends AbstractObservableWithUpstream<T, T> {
2121
private final Consumer<? super Disposable> onSubscribe;
22-
private final Action onCancel;
22+
private final Action onDispose;
2323

2424
public ObservableDoOnLifecycle(Observable<T> upstream, Consumer<? super Disposable> onSubscribe,
25-
Action onCancel) {
25+
Action onDispose) {
2626
super(upstream);
2727
this.onSubscribe = onSubscribe;
28-
this.onCancel = onCancel;
28+
this.onDispose = onDispose;
2929
}
3030

3131
@Override
3232
protected void subscribeActual(Observer<? super T> observer) {
33-
source.subscribe(new SubscriptionLambdaObserver<T>(observer, onSubscribe, onCancel));
33+
source.subscribe(new SubscriptionLambdaObserver<T>(observer, onSubscribe, onDispose));
3434
}
3535
}

‎src/main/java/io/reactivex/internal/operators/single/SingleDoOnCancel.java renamed to ‎src/main/java/io/reactivex/internal/operators/single/SingleDoOnDispose.java

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -20,38 +20,38 @@
2020
import io.reactivex.internal.disposables.DisposableHelper;
2121
import io.reactivex.plugins.RxJavaPlugins;
2222

23-
public final class SingleDoOnCancel<T> extends Single<T> {
23+
public final class SingleDoOnDispose<T> extends Single<T> {
2424
final SingleSource<T> source;
2525

26-
final Action onCancel;
26+
final Action onDispose;
2727

28-
public SingleDoOnCancel(SingleSource<T> source, Action onCancel) {
28+
public SingleDoOnDispose(SingleSource<T> source, Action onDispose) {
2929
this.source = source;
30-
this.onCancel = onCancel;
30+
this.onDispose = onDispose;
3131
}
3232

3333
@Override
3434
protected void subscribeActual(final SingleObserver<? super T> s) {
3535

36-
source.subscribe(new DoOnCancelObserver<T>(s, onCancel));
36+
source.subscribe(new DoOnDisposeObserver<T>(s, onDispose));
3737
}
3838

39-
static final class DoOnCancelObserver<T> implements SingleObserver<T>, Disposable {
39+
static final class DoOnDisposeObserver<T> implements SingleObserver<T>, Disposable {
4040
final SingleObserver<? super T> actual;
4141

42-
final Action onCancel;
42+
final Action onDispose;
4343

4444
Disposable d;
4545

46-
public DoOnCancelObserver(SingleObserver<? super T> actual, Action onCancel) {
46+
public DoOnDisposeObserver(SingleObserver<? super T> actual, Action onDispose) {
4747
this.actual = actual;
48-
this.onCancel = onCancel;
48+
this.onDispose = onDispose;
4949
}
5050

5151
@Override
5252
public void dispose() {
5353
try {
54-
onCancel.run();
54+
onDispose.run();
5555
} catch (Throwable ex) {
5656
Exceptions.throwIfFatal(ex);
5757
RxJavaPlugins.onError(ex);

‎src/main/java/io/reactivex/internal/subscribers/observable/SubscriptionLambdaObserver.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -23,16 +23,16 @@
2323
public final class SubscriptionLambdaObserver<T> implements Observer<T>, Disposable {
2424
final Observer<? super T> actual;
2525
final Consumer<? super Disposable> onSubscribe;
26-
final Action onCancel;
26+
final Action onDispose;
2727

2828
Disposable s;
2929

3030
public SubscriptionLambdaObserver(Observer<? super T> actual,
3131
Consumer<? super Disposable> onSubscribe,
32-
Action onCancel) {
32+
Action onDispose) {
3333
this.actual = actual;
3434
this.onSubscribe = onSubscribe;
35-
this.onCancel = onCancel;
35+
this.onDispose = onDispose;
3636
}
3737

3838
@Override
@@ -73,7 +73,7 @@ public void onComplete() {
7373
@Override
7474
public void dispose() {
7575
try {
76-
onCancel.run();
76+
onDispose.run();
7777
} catch (Throwable e) {
7878
Exceptions.throwIfFatal(e);
7979
RxJavaPlugins.onError(e);

‎src/test/java/io/reactivex/internal/operators/observable/ObservableCacheTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -108,7 +108,7 @@ public void accept(String v) {
108108
@Test
109109
public void testUnsubscribeSource() throws Exception {
110110
Action unsubscribe = mock(Action.class);
111-
Observable<Integer> o = Observable.just(1).doOnCancel(unsubscribe).cache();
111+
Observable<Integer> o = Observable.just(1).doOnDispose(unsubscribe).cache();
112112
o.subscribe();
113113
o.subscribe();
114114
o.subscribe();

‎src/test/java/io/reactivex/internal/operators/observable/ObservableDelayTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -212,7 +212,7 @@ public void testDelaySubscription() {
212212
}
213213

214214
@Test
215-
public void testDelaySubscriptionCancelBeforeTime() {
215+
public void testDelaySubscriptionDisposeBeforeTime() {
216216
Observable<Integer> result = Observable.just(1, 2, 3).delaySubscription(100, TimeUnit.MILLISECONDS, scheduler);
217217

218218
Observer<Object> o = TestHelper.mockObserver();

‎src/test/java/io/reactivex/internal/operators/observable/ObservableDoOnUnsubscribeTest.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,7 @@ public void testDoOnUnsubscribe() throws Exception {
4141
// The stream needs to be infinite to ensure the stream does not terminate
4242
// before it is unsubscribed
4343
.interval(50, TimeUnit.MILLISECONDS)
44-
.doOnCancel(new Action() {
44+
.doOnDispose(new Action() {
4545
@Override
4646
public void run() {
4747
// Test that upper stream will be notified for un-subscription
@@ -57,7 +57,7 @@ public void accept(Long aLong) {
5757
onNextLatch.countDown();
5858
}
5959
})
60-
.doOnCancel(new Action() {
60+
.doOnDispose(new Action() {
6161
@Override
6262
public void run() {
6363
// Test that lower stream will be notified for a direct un-subscription
@@ -103,7 +103,7 @@ public void testDoOnUnSubscribeWorksWithRefCount() throws Exception {
103103
// The stream needs to be infinite to ensure the stream does not terminate
104104
// before it is unsubscribed
105105
.interval(50, TimeUnit.MILLISECONDS)
106-
.doOnCancel(new Action() {
106+
.doOnDispose(new Action() {
107107
@Override
108108
public void run() {
109109
// Test that upper stream will be notified for un-subscription
@@ -118,7 +118,7 @@ public void accept(Long aLong) {
118118
onNextLatch.countDown();
119119
}
120120
})
121-
.doOnCancel(new Action() {
121+
.doOnDispose(new Action() {
122122
@Override
123123
public void run() {
124124
// Test that lower stream will be notified for un-subscription

‎src/test/java/io/reactivex/internal/operators/observable/ObservableIgnoreElementsTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -80,7 +80,7 @@ public void testErrorReceived() {
8080
@Test
8181
public void testUnsubscribesFromUpstream() {
8282
final AtomicBoolean unsub = new AtomicBoolean();
83-
Observable.range(1, 10).doOnCancel(new Action() {
83+
Observable.range(1, 10).doOnDispose(new Action() {
8484
@Override
8585
public void run() {
8686
unsub.set(true);

‎src/test/java/io/reactivex/internal/operators/observable/ObservablePublishTest.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -192,7 +192,7 @@ public void accept(Integer t1) {
192192
sourceEmission.incrementAndGet();
193193
}
194194
})
195-
.doOnCancel(new Action() {
195+
.doOnDispose(new Action() {
196196
@Override
197197
public void run() {
198198
sourceUnsubscribed.set(true);
@@ -209,7 +209,7 @@ public void run() {
209209
@Override
210210
public void onNext(Integer t) {
211211
if (valueCount() == 2) {
212-
source.doOnCancel(new Action() {
212+
source.doOnDispose(new Action() {
213213
@Override
214214
public void run() {
215215
child2Unsubscribed.set(true);
@@ -220,7 +220,7 @@ public void run() {
220220
}
221221
};
222222

223-
source.doOnCancel(new Action() {
223+
source.doOnDispose(new Action() {
224224
@Override
225225
public void run() {
226226
child1Unsubscribed.set(true);

‎src/test/java/io/reactivex/internal/operators/observable/ObservableRefCountTest.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -170,7 +170,7 @@ public void accept(Disposable s) {
170170
subscribeCount.incrementAndGet();
171171
}
172172
})
173-
.doOnCancel(new Action() {
173+
.doOnDispose(new Action() {
174174
@Override
175175
public void run() {
176176
System.out.println("******************************* Unsubscribe received");
@@ -215,7 +215,7 @@ public void accept(Disposable s) {
215215
subscribeLatch.countDown();
216216
}
217217
})
218-
.doOnCancel(new Action() {
218+
.doOnDispose(new Action() {
219219
@Override
220220
public void run() {
221221
System.out.println("******************************* Unsubscribe received");
@@ -253,7 +253,7 @@ public void testConnectUnsubscribeRaceConditionLoop() throws InterruptedExceptio
253253
public void testConnectUnsubscribeRaceCondition() throws InterruptedException {
254254
final AtomicInteger subUnsubCount = new AtomicInteger();
255255
Observable<Long> o = synchronousInterval()
256-
.doOnCancel(new Action() {
256+
.doOnDispose(new Action() {
257257
@Override
258258
public void run() {
259259
System.out.println("******************************* Unsubscribe received");

‎src/test/java/io/reactivex/internal/operators/observable/ObservableReplayTest.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -522,7 +522,7 @@ public void testIssue2191_UnsubscribeSource() throws Exception {
522522

523523
ConnectableObservable<Integer> replay = source
524524
.doOnNext(sourceNext)
525-
.doOnCancel(sourceUnsubscribed)
525+
.doOnDispose(sourceUnsubscribed)
526526
.doOnComplete(sourceCompleted)
527527
.replay();
528528

@@ -572,7 +572,7 @@ public void testIssue2191_SchedulerUnsubscribe() throws Exception {
572572
// NbpObservable under test
573573
ConnectableObservable<Integer> replay = Observable.just(1, 2, 3)
574574
.doOnNext(sourceNext)
575-
.doOnCancel(sourceUnsubscribed)
575+
.doOnDispose(sourceUnsubscribed)
576576
.doOnComplete(sourceCompleted)
577577
.subscribeOn(mockScheduler).replay();
578578

@@ -629,7 +629,7 @@ public void testIssue2191_SchedulerUnsubscribeOnError() throws Exception {
629629
when(mockFunc.apply(2)).thenThrow(illegalArgumentException);
630630
ConnectableObservable<Integer> replay = Observable.just(1, 2, 3).map(mockFunc)
631631
.doOnNext(sourceNext)
632-
.doOnCancel(sourceUnsubscribed)
632+
.doOnDispose(sourceUnsubscribed)
633633
.doOnComplete(sourceCompleted)
634634
.doOnError(sourceError)
635635
.subscribeOn(mockScheduler).replay();
@@ -850,7 +850,7 @@ public void accept(String v) {
850850
@Test
851851
public void testUnsubscribeSource() throws Exception {
852852
Action unsubscribe = mock(Action.class);
853-
Observable<Integer> o = Observable.just(1).doOnCancel(unsubscribe).cache();
853+
Observable<Integer> o = Observable.just(1).doOnDispose(unsubscribe).cache();
854854
o.subscribe();
855855
o.subscribe();
856856
o.subscribe();

‎src/test/java/io/reactivex/internal/operators/observable/ObservableTakeLastOneTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -67,7 +67,7 @@ public void run() {
6767
unsubscribed.set(true);
6868
}
6969
};
70-
Observable.just(1).doOnCancel(unsubscribeAction)
70+
Observable.just(1).doOnDispose(unsubscribeAction)
7171
.takeLast(1).subscribe();
7272
assertTrue(unsubscribed.get());
7373
}

‎src/test/java/io/reactivex/internal/operators/observable/ObservableUsingTest.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -291,7 +291,7 @@ public Observable<String> apply(Resource resource) {
291291

292292
Observable<String> o = Observable.using(resourceFactory, observableFactory,
293293
new DisposeAction(), true)
294-
.doOnCancel(unsub)
294+
.doOnDispose(unsub)
295295
.doOnComplete(completion);
296296

297297
o.safeSubscribe(NbpObserver);
@@ -318,7 +318,7 @@ public Observable<String> apply(Resource resource) {
318318

319319
Observable<String> o = Observable.using(resourceFactory, observableFactory,
320320
new DisposeAction(), false)
321-
.doOnCancel(unsub)
321+
.doOnDispose(unsub)
322322
.doOnComplete(completion);
323323

324324
o.safeSubscribe(NbpObserver);
@@ -348,7 +348,7 @@ public Observable<String> apply(Resource resource) {
348348

349349
Observable<String> o = Observable.using(resourceFactory, observableFactory,
350350
new DisposeAction(), true)
351-
.doOnCancel(unsub)
351+
.doOnDispose(unsub)
352352
.doOnError(onError);
353353

354354
o.safeSubscribe(NbpObserver);
@@ -376,7 +376,7 @@ public Observable<String> apply(Resource resource) {
376376

377377
Observable<String> o = Observable.using(resourceFactory, observableFactory,
378378
new DisposeAction(), false)
379-
.doOnCancel(unsub)
379+
.doOnDispose(unsub)
380380
.doOnError(onError);
381381

382382
o.safeSubscribe(NbpObserver);

‎src/test/java/io/reactivex/internal/operators/single/SingleDoOnTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -25,10 +25,10 @@
2525
public class SingleDoOnTest {
2626

2727
@Test
28-
public void doOnCancel() {
28+
public void doOnDispose() {
2929
final int[] count = { 0 };
3030

31-
Single.never().doOnCancel(new Action() {
31+
Single.never().doOnDispose(new Action() {
3232
@Override
3333
public void run() throws Exception {
3434
count[0]++;

‎src/test/java/io/reactivex/observable/ObservableNullTests.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1267,8 +1267,8 @@ public Object apply(Integer v) {
12671267
}
12681268

12691269
@Test(expected = NullPointerException.class)
1270-
public void doOnCancelNull() {
1271-
just1.doOnCancel(null);
1270+
public void doOnDisposeNull() {
1271+
just1.doOnDispose(null);
12721272
}
12731273

12741274
@Test(expected = NullPointerException.class)
@@ -1297,7 +1297,7 @@ public void doOnLifecycleOnSubscribeNull() {
12971297
}
12981298

12991299
@Test(expected = NullPointerException.class)
1300-
public void doOnLifecycleOnCancelNull() {
1300+
public void doOnLifecycleOnDisposeNull() {
13011301
just1.doOnLifecycle(new Consumer<Disposable>() {
13021302
@Override
13031303
public void accept(Disposable s) { }

‎src/test/java/io/reactivex/single/SingleNullTests.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -602,8 +602,8 @@ public void doOnError() {
602602
}
603603

604604
@Test(expected = NullPointerException.class)
605-
public void doOnCancelNull() {
606-
just1.doOnCancel(null);
605+
public void doOnDisposeNull() {
606+
just1.doOnDispose(null);
607607
}
608608

609609
@Test(expected = NullPointerException.class)

0 commit comments

Comments
 (0)