Merge pull request #3091 from akarnokd/AutoConnectFix

Fix autoConnect calling onStart twice.
ReactiveX · Jul 20, 2015 · 29b9de2 · 29b9de2
2 parents e4000b3 + d43b3d1
commit 29b9de2
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/src/main/java/rx/internal/operators/OnSubscribeAutoConnect.java b/src/main/java/rx/internal/operators/OnSubscribeAutoConnect.java
@@ -18,9 +18,11 @@
 import java.util.concurrent.atomic.AtomicInteger;
 
 import rx.Observable.OnSubscribe;
-import rx.*;
+import rx.Subscriber;
+import rx.Subscription;
 import rx.functions.Action1;
 import rx.observables.ConnectableObservable;
+import rx.observers.Subscribers;
 
 /**
  * Wraps a ConnectableObservable and calls its connect() method once
@@ -47,7 +49,7 @@ public OnSubscribeAutoConnect(ConnectableObservable<? extends T> source,
     }
     @Override
     public void call(Subscriber<? super T> child) {
-        source.unsafeSubscribe(child);
+        source.unsafeSubscribe(Subscribers.wrap(child));
         if (clients.incrementAndGet() == numberOfSubscribers) {
             source.connect(connection);
         }