Skip to content

Commit 8811831

Browse files
committed
1.x add missing @experimental tag to unsubscribeOn
1 parent c8e22d8 commit 8811831

File tree

4 files changed

+4
-3
lines changed

4 files changed

+4
-3
lines changed

src/main/java/rx/Single.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2813,7 +2813,9 @@ public final Single<T> delaySubscription(Observable<?> other) {
28132813
* the dispose is called on the specified scheduler
28142814
* @param scheduler the target scheduler where to execute the cancellation
28152815
* @return the new Single instance
2816+
* @since 1.2.8 - experimental
28162817
*/
2818+
@Experimental
28172819
public final Single<T> unsubscribeOn(final Scheduler scheduler) {
28182820
return create(new OnSubscribe<T>() {
28192821
@Override

src/test/java/rx/SingleTest.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,6 @@
2828
import rx.Single.OnSubscribe;
2929
import rx.exceptions.*;
3030
import rx.functions.*;
31-
import rx.internal.util.RxThreadFactory;
3231
import rx.observers.*;
3332
import rx.plugins.RxJavaHooks;
3433
import rx.schedulers.*;

src/test/java/rx/internal/operators/OperatorReplayTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1584,7 +1584,7 @@ public void noOldEntries() {
15841584
Observable<Integer> source = Observable.just(1)
15851585
.replay(2, TimeUnit.SECONDS, scheduler)
15861586
.autoConnect();
1587-
1587+
15881588
source.test().assertResult(1);
15891589

15901590
source.test().assertResult(1);

src/test/java/rx/subjects/ReplaySubjectTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1183,7 +1183,7 @@ public void noOldEntries() {
11831183

11841184
source.onNext(1);
11851185
source.onCompleted();
1186-
1186+
11871187
source.test().assertResult(1);
11881188

11891189
source.test().assertResult(1);

0 commit comments

Comments
 (0)