|
@@ 113-120 (lines=8) @@
|
| 110 |
|
assertThat(iterator_to_array($iterator), is(identicalTo($this->messages))); |
| 111 |
|
} |
| 112 |
|
|
| 113 |
|
public function testDequeueWithNoMessages() |
| 114 |
|
{ |
| 115 |
|
$adapter = new ArrayAdapter(); |
| 116 |
|
|
| 117 |
|
$iterator = $adapter->dequeue($this->factory, null); |
| 118 |
|
|
| 119 |
|
assertThat(iterator_to_array($iterator), is(emptyArray())); |
| 120 |
|
} |
| 121 |
|
|
| 122 |
|
public function testDequeueWithLimitAndNoMessages() |
| 123 |
|
{ |
|
@@ 122-129 (lines=8) @@
|
| 119 |
|
assertThat(iterator_to_array($iterator), is(emptyArray())); |
| 120 |
|
} |
| 121 |
|
|
| 122 |
|
public function testDequeueWithLimitAndNoMessages() |
| 123 |
|
{ |
| 124 |
|
$adapter = new ArrayAdapter(); |
| 125 |
|
|
| 126 |
|
$iterator = $adapter->dequeue($this->factory, 10); |
| 127 |
|
|
| 128 |
|
assertThat(iterator_to_array($iterator), is(emptyArray())); |
| 129 |
|
} |
| 130 |
|
|
| 131 |
|
public function testEnqueue() |
| 132 |
|
{ |