1
0
mirror of https://github.com/danog/amp.git synced 2024-12-12 09:29:45 +01:00
amp/lib/Delayed.php

39 lines
1.1 KiB
PHP
Raw Normal View History

<?php
2016-08-16 06:46:26 +02:00
2016-05-24 05:48:28 +02:00
namespace Amp;
2016-06-01 19:18:11 +02:00
/**
2016-11-14 20:59:21 +01:00
* Creates a promise that resolves itself with a given value after a number of milliseconds.
2016-06-01 19:18:11 +02:00
*/
final class Delayed implements Promise {
use Internal\Placeholder;
/** @var string Event loop watcher identifier. */
private $watcher;
/**
* @param int $time Milliseconds before succeeding the promise.
2016-11-14 20:59:21 +01:00
* @param mixed $value Succeed the promise with this value.
*/
2016-08-11 21:35:58 +02:00
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);
}
}