(self, amount=None)
| 82 | self._transfer_coordinator = transfer_coordinator |
| 83 | |
| 84 | def read(self, amount=None): |
| 85 | # If there is an exception, then raise the exception. |
| 86 | # We raise an error instead of returning no bytes because for |
| 87 | # requests where the content length and md5 was sent, it will |
| 88 | # cause md5 mismatches and retries as there was no indication that |
| 89 | # the stream being read from encountered any issues. |
| 90 | if self._transfer_coordinator.exception: |
| 91 | raise self._transfer_coordinator.exception |
| 92 | return self._fileobj.read(amount) |
| 93 | |
| 94 | def seek(self, where, whence=0): |
| 95 | self._fileobj.seek(where, whence) |
no outgoing calls