(self)
| 87 | return _PickleFifoSerializationDiskQueue(self.qpath, chunksize=self.chunksize) |
| 88 | |
| 89 | def test_serialize_item(self): |
| 90 | q = self.queue() |
| 91 | i = MyItem(name="foo") |
| 92 | q.push(i) |
| 93 | i2 = q.pop() |
| 94 | assert isinstance(i2, MyItem) |
| 95 | assert i == i2 |
| 96 | |
| 97 | def test_serialize_loader(self): |
| 98 | q = self.queue() |