mirror of
https://github.com/danog/amp.git
synced 2025-01-22 13:21:16 +01:00
allow nested tick
This commit is contained in:
parent
1fa9771dde
commit
09e000a6d7
@ -169,10 +169,6 @@ class EvReactor implements ExtensionReactor {
|
|||||||
* {@inheritdoc}
|
* {@inheritdoc}
|
||||||
*/
|
*/
|
||||||
public function tick($noWait = false) {
|
public function tick($noWait = false) {
|
||||||
if ($this->isRunning) {
|
|
||||||
// If we're already running/ticking this method is superfluous
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
$noWait = (bool) $noWait;
|
$noWait = (bool) $noWait;
|
||||||
$this->isRunning = true;
|
$this->isRunning = true;
|
||||||
|
|
||||||
|
@ -123,10 +123,6 @@ class LibeventReactor implements ExtensionReactor {
|
|||||||
* {@inheritDoc}
|
* {@inheritDoc}
|
||||||
*/
|
*/
|
||||||
public function tick($noWait = false) {
|
public function tick($noWait = false) {
|
||||||
if ($this->isRunning) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
$noWait = (bool) $noWait;
|
$noWait = (bool) $noWait;
|
||||||
$this->isRunning = true;
|
$this->isRunning = true;
|
||||||
|
|
||||||
|
@ -129,10 +129,6 @@ class UvReactor implements ExtensionReactor {
|
|||||||
* {@inheritDoc}
|
* {@inheritDoc}
|
||||||
*/
|
*/
|
||||||
public function tick($noWait = false) {
|
public function tick($noWait = false) {
|
||||||
if ($this->isRunning) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
$noWait = (bool) $noWait;
|
$noWait = (bool) $noWait;
|
||||||
$this->isRunning = true;
|
$this->isRunning = true;
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user