Skip to content

Commit 531ff06

Browse files
committed
Merge and work on RefCount
1 parent 60ad0cf commit 531ff06

File tree

2 files changed

+1
-13
lines changed

2 files changed

+1
-13
lines changed

rxjava-core/src/main/java/rx/observables/ConnectableObservable.java

Lines changed: 1 addition & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -54,17 +54,6 @@ protected ConnectableObservable(OnSubscribeFunc<T> onSubscribe) {
5454
* @return a {@link Observable}
5555
*/
5656
public Observable<T> refCount() {
57-
return refCount(this);
58-
}
59-
60-
/**
61-
* Returns an observable sequence that stays connected to the source as long
62-
* as there is at least one subscription to the observable sequence.
63-
* @param that
64-
* a {@link ConnectableObservable}
65-
* @return a {@link Observable}
66-
*/
67-
public static <T> Observable<T> refCount(ConnectableObservable<T> that) {
68-
return Observable.create(OperationRefCount.refCount(that));
57+
return Observable.create(OperationRefCount.refCount(this));
6958
}
7059
}

rxjava-core/src/main/java/rx/operators/OperationRefCount.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -70,7 +70,6 @@ public void call() {
7070
});
7171
}
7272

73-
@RunWith(JUnit4.class)
7473
public static class UnitTest {
7574

7675
@Before

0 commit comments

Comments
 (0)