mirror of
https://github.com/danog/parallel.git
synced 2024-11-30 04:39:01 +01:00
Add internal annotations
This commit is contained in:
parent
3d5e1c6e6f
commit
0df4fa9cce
@ -4,6 +4,7 @@ namespace Amp\Parallel\Worker\Internal;
|
||||
|
||||
use Amp\Parallel\Worker\Task;
|
||||
|
||||
/** @internal */
|
||||
class Job {
|
||||
/** @var string */
|
||||
private $id;
|
||||
|
@ -6,6 +6,7 @@ use Amp\Parallel\Worker\Task;
|
||||
use Amp\Parallel\Worker\Worker;
|
||||
use Amp\Promise;
|
||||
|
||||
/** @internal */
|
||||
class PooledWorker implements Worker {
|
||||
/** @var callable */
|
||||
private $push;
|
||||
|
@ -7,6 +7,7 @@ use Amp\Parallel\Worker\TaskError;
|
||||
use Amp\Parallel\Worker\TaskException;
|
||||
use Amp\Promise;
|
||||
|
||||
/** @internal */
|
||||
class TaskFailure extends TaskResult {
|
||||
const PARENT_EXCEPTION = 0;
|
||||
const PARENT_ERROR = 1;
|
||||
|
@ -4,6 +4,7 @@ namespace Amp\Parallel\Worker\Internal;
|
||||
|
||||
use Amp\Promise;
|
||||
|
||||
/** @internal */
|
||||
abstract class TaskResult {
|
||||
/** @var string Task identifier. */
|
||||
private $id;
|
||||
|
@ -5,6 +5,7 @@ namespace Amp\Parallel\Worker\Internal;
|
||||
use Amp\Promise;
|
||||
use Amp\Success;
|
||||
|
||||
/** @internal */
|
||||
class TaskSuccess extends TaskResult {
|
||||
/** @var mixed Result of task. */
|
||||
private $result;
|
||||
|
Loading…
Reference in New Issue
Block a user