Fix OperationalConditional

All unit tests now pass.

Author: benjchristensen

rxjava-contrib/rxjava-computation-expressions/src/main/java/rx/operators/OperationConditionals.java

@@ -21,6 +21,7 @@
 import rx.Observable.OnSubscribeFunc;
 import rx.Observer;
 import rx.Subscription;
+import rx.subscriptions.MultipleAssignmentSubscription;
 import rx.subscriptions.SerialSubscription;
 import rx.subscriptions.Subscriptions;
 import rx.util.functions.Func0;
@@ -231,7 +232,7 @@ public Subscription onSubscribe(Observer<? super T> t1) {
                 return Subscriptions.empty();
             }
             if (first) {
-                SerialSubscription ssub = new SerialSubscription();
+                MultipleAssignmentSubscription ssub = new MultipleAssignmentSubscription();
 
                 ssub.set(source.subscribe(new SourceObserver(t1, ssub)));
 
@@ -244,10 +245,10 @@ public Subscription onSubscribe(Observer<? super T> t1) {
 
         /** Observe the source. */
         final class SourceObserver extends Observer<T> {
-            final SerialSubscription cancel;
+            final MultipleAssignmentSubscription cancel;
             final Observer<? super T> observer;
 
-            public SourceObserver(Observer<? super T> observer, SerialSubscription cancel) {
+            public SourceObserver(Observer<? super T> observer, MultipleAssignmentSubscription cancel) {
                 this.observer = observer;
                 this.cancel = cancel;
             }

rxjava-contrib/rxjava-computation-expressions/src/test/java/rx/operators/OperationConditionalsTest.java

@@ -403,7 +403,6 @@ public Boolean call() {
 
     @Test
     public void testDoWhileManyTimes() {
-        fail("deadlocking");
         Observable<Integer> source1 = Observable.from(1, 2, 3).subscribeOn(Schedulers.currentThread());
 
         List<Integer> expected = new ArrayList<Integer>(numRecursion * 3);