| 232 | self._shutdown(cancel) |
| 233 | |
| 234 | def download( |
| 235 | self, bucket, key, fileobj, extra_args=None, subscribers=None |
| 236 | ): |
| 237 | if extra_args is None: |
| 238 | extra_args = {} |
| 239 | if subscribers is None: |
| 240 | subscribers = {} |
| 241 | callargs = CallArgs( |
| 242 | bucket=bucket, |
| 243 | key=key, |
| 244 | fileobj=fileobj, |
| 245 | extra_args=extra_args, |
| 246 | subscribers=subscribers, |
| 247 | ) |
| 248 | return self._submit_transfer("get_object", callargs) |
| 249 | |
| 250 | def upload(self, fileobj, bucket, key, extra_args=None, subscribers=None): |
| 251 | if extra_args is None: |