| 1 | <?php |
||
| 16 | class MessageQueue implements Iterator, Countable |
||
| 17 | { |
||
| 18 | /** |
||
| 19 | * @var SplQueue |
||
| 20 | */ |
||
| 21 | private $queue; |
||
| 22 | |||
| 23 | 22 | public function __construct() |
|
| 28 | |||
| 29 | 7 | public function enqueue(MessageInterface $message) |
|
| 33 | |||
| 34 | 3 | public function dequeue() |
|
| 38 | |||
| 39 | 9 | public function isEmpty() |
|
| 43 | |||
| 44 | /** |
||
| 45 | * @inheritdoc |
||
| 46 | */ |
||
| 47 | 7 | public function current() |
|
| 51 | |||
| 52 | /** |
||
| 53 | * @inheritdoc |
||
| 54 | */ |
||
| 55 | 7 | public function next() |
|
| 59 | |||
| 60 | /** |
||
| 61 | * @inheritdoc |
||
| 62 | */ |
||
| 63 | 1 | public function key() |
|
| 67 | |||
| 68 | /** |
||
| 69 | * @inheritdoc |
||
| 70 | */ |
||
| 71 | 7 | public function valid() |
|
| 75 | |||
| 76 | /** |
||
| 77 | * @inheritdoc |
||
| 78 | */ |
||
| 79 | 7 | public function rewind() |
|
| 83 | |||
| 84 | /** |
||
| 85 | * @inheritdoc |
||
| 86 | */ |
||
| 87 | 3 | public function count() |
|
| 91 | } |