1 | <?php |
||
13 | class SyncAdapter extends Adapter |
||
14 | { |
||
15 | /** |
||
16 | * Pull next job from the queue. |
||
17 | * |
||
18 | * @return Job |
||
19 | */ |
||
20 | 1 | public function next(): ?Job |
|
24 | |||
25 | /** |
||
26 | * Push command onto the queue. |
||
27 | * |
||
28 | * @param Channel $channel |
||
29 | * @param Driver $driver |
||
30 | * @param Command $command |
||
31 | */ |
||
32 | 2 | public function push(Channel $channel, Driver $driver, Command $command): void |
|
36 | |||
37 | /** |
||
38 | * Push command onto the queue with a delay. |
||
39 | * |
||
40 | * @param Channel $channel |
||
41 | * @param Driver $driver |
||
42 | * @param Command $command |
||
43 | * @param int $delay |
||
44 | * |
||
45 | * @return mixed|void |
||
46 | */ |
||
47 | 1 | public function later(Channel $channel, Driver $driver, Command $command, int $delay): void |
|
55 | } |
||
56 |