Wrapper for a read only stream that adds progress callbacks.
| 332 | |
| 333 | |
| 334 | class StreamReaderProgress: |
| 335 | """Wrapper for a read only stream that adds progress callbacks.""" |
| 336 | |
| 337 | def __init__(self, stream, callback=None): |
| 338 | self._stream = stream |
| 339 | self._callback = callback |
| 340 | |
| 341 | def read(self, *args, **kwargs): |
| 342 | value = self._stream.read(*args, **kwargs) |
| 343 | if self._callback is not None: |
| 344 | self._callback(len(value)) |
| 345 | return value |
| 346 | |
| 347 | |
| 348 | class OSUtils: |
no outgoing calls
no test coverage detected