-
-
Notifications
You must be signed in to change notification settings - Fork 255
/
Delayed.php
38 lines (32 loc) · 1.07 KB
/
Delayed.php
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
<?php
namespace Amp;
/**
* Creates a promise that resolves itself with a given value after a number of milliseconds.
*/
final class Delayed implements Promise {
use Internal\Placeholder;
/** @var string Event loop watcher identifier. */
private $watcher;
/**
* @param int $time Milliseconds before succeeding the promise.
* @param mixed $value Succeed the promise with this value.
*/
public function __construct(int $time, $value = null) {
$this->watcher = Loop::delay($time, function () use ($value) {
$this->resolve($value);
});
}
/**
* References the internal watcher in the event loop, keeping the loop running while this promise is pending.
*/
public function reference() {
Loop::reference($this->watcher);
}
/**
* Unreferences the internal watcher in the event loop, allowing the loop to stop while this promise is pending if
* no other events are pending in the loop.
*/
public function unreference() {
Loop::unreference($this->watcher);
}
}