danog/amp
1
0
Fork 0
mirror of https://github.com/danog/amp.git synced 2024-12-02 17:37:50 +01:00
Code Issues Projects Releases Wiki Activity

Add $data parameter to watchers

Browse Source
This commit is contained in:
Aaron Piotrowski 2016-05-14 17:13:35 -05:00
parent 95c2f35e60
commit 38a3da4889
2 changed files with 30 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
src/Loop.php
View File

@ -60,12 +60,13 @@ final class Loop
* Defer the execution of a callback.
*
* @param callable $callback The callback to defer.
* @param mixed $data Arbitrary data given to the callback function as the $data parameter.
*
* @return string An identifier that can be used to cancel, enable or disable the event.
*/
public static function defer(callable $callback)
public static function defer(callable $callback, $data = null)
{
return self::get()->defer($callback);
return self::get()->defer($callback, $data);
}
/**
@ -73,12 +74,13 @@ final class Loop
*
* @param callable $callback The callback to delay.
* @param int $time The amount of time, in milliseconds, to delay the execution for.
* @param mixed $data Arbitrary data given to the callback function as the $data parameter.
*
* @return string An identifier that can be used to cancel, enable or disable the event.
*/
public static function delay(callable $callback, $time)
public static function delay(callable $callback, $time, $data = null)
{
return self::get()->delay($callback, $time);
return self::get()->delay($callback, $time, $data);
}
/**
@ -86,12 +88,13 @@ final class Loop
*
* @param callable $callback The callback to repeat.
* @param int $interval The time interval, in milliseconds, to wait between executions.
* @param mixed $data Arbitrary data given to the callback function as the $data parameter.
*
* @return string An identifier that can be used to cancel, enable or disable the event.
*/
public static function repeat(callable $callback, $interval)
public static function repeat(callable $callback, $interval, $data = null)
{
return self::get()->repeat($callback, $interval);
return self::get()->repeat($callback, $interval, $data);
}
/**
@ -99,12 +102,13 @@ final class Loop
*
* @param resource $stream The stream to monitor.
* @param callable $callback The callback to execute.
* @param mixed $data Arbitrary data given to the callback function as the $data parameter.
*
* @return string An identifier that can be used to cancel, enable or disable the event.
*/
public static function onReadable($stream, callable $callback)
public static function onReadable($stream, callable $callback, $data = null)
{
return self::get()->onReadable($stream, $callback);
return self::get()->onReadable($stream, $callback, $data);
}
/**
@ -112,12 +116,13 @@ final class Loop
*
* @param resource $stream The stream to monitor.
* @param callable $callback The callback to execute.
* @param mixed $data Arbitrary data given to the callback function as the $data parameter.
*
* @return string An identifier that can be used to cancel, enable or disable the event.
*/
public static function onWritable($stream, callable $callback)
public static function onWritable($stream, callable $callback, $data = null)
{
return self::get()->onWritable($stream, $callback);
return self::get()->onWritable($stream, $callback, $data);
}
/**
@ -125,12 +130,13 @@ final class Loop
*
* @param int $signo The signal number to monitor.
* @param callable $callback The callback to execute.
* @param mixed $data Arbitrary data given to the callback function as the $data parameter.
*
* @return string An identifier that can be used to cancel, enable or disable the event.
*/
public static function onSignal($signo, callable $callback)
public static function onSignal($signo, callable $callback, $data = null)
{
return self::get()->onSignal($signo, $callback);
return self::get()->onSignal($signo, $callback, $data);
}
/**

18
src/LoopDriver.php
View File

@ -24,60 +24,66 @@ interface LoopDriver
* Defer the execution of a callback.
*
* @param callable $callback The callback to defer.
* @param mixed $data Arbitrary data given to the callback function as the $data parameter.
*
* @return string An identifier that can be used to cancel, enable or disable the event.
*/
public function defer(callable $callback);
public function defer(callable $callback, $data = null);
/**
* Delay the execution of a callback. The time delay is approximate and accuracy is not guaranteed.
*
* @param callable $callback The callback to delay.
* @param int $delay The amount of time, in milliseconds, to delay the execution for.
* @param mixed $data Arbitrary data given to the callback function as the $data parameter.
*
* @return string An identifier that can be used to cancel, enable or disable the event.
*/
public function delay(callable $callback, $delay);
public function delay(callable $callback, $delay, $data = null);
/**
* Repeatedly execute a callback. The interval between executions is approximate and accuracy is not guaranteed.
*
* @param callable $callback The callback to repeat.
* @param int $interval The time interval, in milliseconds, to wait between executions.
* @param mixed $data Arbitrary data given to the callback function as the $data parameter.
*
* @return string An identifier that can be used to cancel, enable or disable the event.
*/
public function repeat(callable $callback, $interval);
public function repeat(callable $callback, $interval, $data = null);
/**
* Execute a callback when a stream resource becomes readable.
*
* @param resource $stream The stream to monitor.
* @param callable $callback The callback to execute.
* @param mixed $data Arbitrary data given to the callback function as the $data parameter.
*
* @return string An identifier that can be used to cancel, enable or disable the event.
*/
public function onReadable($stream, callable $callback);
public function onReadable($stream, callable $callback, $data = null);
/**
* Execute a callback when a stream resource becomes writable.
*
* @param resource $stream The stream to monitor.
* @param callable $callback The callback to execute.
* @param mixed $data Arbitrary data given to the callback function as the $data parameter.
*
* @return string An identifier that can be used to cancel, enable or disable the event.
*/
public function onWritable($stream, callable $callback);
public function onWritable($stream, callable $callback, $data = null);
/**
* Execute a callback when a signal is received.
*
* @param int $signo The signal number to monitor.
* @param callable $callback The callback to execute.
* @param mixed $data Arbitrary data given to the callback function as the $data parameter.
*
* @return string An identifier that can be used to cancel, enable or disable the event.
*/
public function onSignal($signo, callable $callback);
public function onSignal($signo, callable $callback, $data = null);
/**
* Execute a callback when an error occurs.