Unreference watcher in Amp\timout()

amphp · Dec 17, 2016 · bc1ae18 · bc1ae18
1 parent 8ef760f
commit bc1ae18
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/lib/functions.php b/lib/functions.php
@@ -398,6 +398,7 @@ function timeout(Promise $promise, int $timeout): Promise {
             $deferred->fail(new TimeoutException);
         }
     });
+    Loop::unreference($watcher);
 
     $promise->when(function () use (&$resolved, $promise, $deferred, $watcher) {
         Loop::cancel($watcher);