Fix zip(); udpate merge()

src/Observable/functions.php

@@ -80,12 +80,14 @@ function merge(array $observables)
                 return new Coroutine($observable->each($emit));
             }, $observables);
 
-            yield Awaitable\all($coroutines)->then(null, function (\Exception $exception) use ($coroutines) {
+            try {
+                yield Awaitable\all($coroutines);
+            } catch (\Exception $exception) {
                 foreach ($coroutines as $coroutine) {
                     $coroutine->cancel($exception);
                 }
                 throw $exception;
-            });
+            }
         });
     }
 
@@ -195,11 +197,14 @@ function ($value) use (&$i, &$next, &$delayed, $key, $count, $emit) {
                 ));
             }
 
-            yield Awaitable\choose($coroutines)->cleanup(function () use ($coroutines) {
+            try {
+                yield Awaitable\choose($coroutines);
+                yield $delayed;
+            } finally {
                 foreach ($coroutines as $coroutine) {
                     $coroutine->cancel();
                 }
-            });
+            }
 
             yield $i; // Return the number of times a set was emitted.
         });