| 125 | return self |
| 126 | |
| 127 | def append(self, value): |
| 128 | with self._lock: |
| 129 | self.chunks[-1].append(value) |
| 130 | |
| 131 | if self.chunk_length == sys.maxsize: |
| 132 | self._size_counter += _size_of(value) |
| 133 | if self._size_counter >= self._chunk_size: |
| 134 | self.chunk_length = len(self.chunks[-1]) |
| 135 | self._size_counter = None |
| 136 | |
| 137 | if len(self.chunks[-1]) >= self.chunk_length: |
| 138 | filename = self._dump(self.chunks[-1]) |
| 139 | self.chunks[-1] = filename |
| 140 | self.chunks.append([]) |
| 141 | |
| 142 | def extend(self, value): |
| 143 | for _ in value: |