src/main/java/rx/internal/operators/OnSubscribeRefCount.java
Method doSubscribe
has 32 lines of code (exceeds 25 allowed). Consider refactoring. Open
Open
void doSubscribe(final Subscriber<? super T> subscriber, final CompositeSubscription currentBase) {
// handle unsubscribing from the base subscription
subscriber.add(disconnect(currentBase));
source.unsafeSubscribe(new Subscriber<T>(subscriber) {