Merge pull request #59 from mbonneau/retryWhen_skip

Remove skipped `retryWhen` test make `retryWhen` correction

Author: davidwdan

lib/Rx/Operator/RetryWhenOperator.php

@@ -90,8 +90,11 @@ function ($x) use ($subscribeToSource, &$sourceError) {
                 }
             },
             [$observer, 'onError'],
-            function () use (&$innerCompleted) {
+            function () use (&$innerCompleted, &$sourceError, $observer) {
                 $innerCompleted = true;
+                if ($sourceError) {
+                    $observer->onCompleted();
+                }
             }
         ), $scheduler);
 

test/Rx/Functional/Operator/RetryWhenTest.php

@@ -204,8 +204,6 @@ public function retryWhen_Observable_complete()
      */
     public function retryWhen_Observable_next_complete()
     {
-        $this->markTestSkipped("skip until takeWhile is implemented");
-
         $error = new \Exception();
 
         $xs = $this->createColdObservable([