| 125 | self._parts_decoded = 0 |
| 126 | |
| 127 | def receive_data(self, data: bytes | None) -> None: |
| 128 | if data is None: |
| 129 | self.complete = True |
| 130 | elif ( |
| 131 | self.max_form_memory_size is not None |
| 132 | and len(self.buffer) + len(data) > self.max_form_memory_size |
| 133 | ): |
| 134 | # Ensure that data within single event does not exceed limit. |
| 135 | # Also checked across accumulated events in MultiPartParser. |
| 136 | raise RequestEntityTooLarge() |
| 137 | else: |
| 138 | self.buffer.extend(data) |
| 139 | |
| 140 | def next_event(self) -> Event: |
| 141 | event: Event = NEED_DATA |