(self, *args, **kwargs)
| 605 | self._callbacks = [] |
| 606 | |
| 607 | def read(self, *args, **kwargs): |
| 608 | value = self._stream.read(*args, **kwargs) |
| 609 | invoke_progress_callbacks(self._callbacks, len(value)) |
| 610 | return value |
| 611 | |
| 612 | |
| 613 | class NoResourcesAvailable(Exception): |