Queue IO write for submission to the IO executor. This method accepts an IO executor and information about the downloaded data, and handles submitting this to the IO executor. This method may defer submission to the IO executor if necessary.
(self, fileobj, data, offset)
| 95 | raise NotImplementedError('must implement get_fileobj_for_io_writes()') |
| 96 | |
| 97 | def queue_file_io_task(self, fileobj, data, offset): |
| 98 | """Queue IO write for submission to the IO executor. |
| 99 | |
| 100 | This method accepts an IO executor and information about the |
| 101 | downloaded data, and handles submitting this to the IO executor. |
| 102 | |
| 103 | This method may defer submission to the IO executor if necessary. |
| 104 | |
| 105 | """ |
| 106 | self._transfer_coordinator.submit( |
| 107 | self._io_executor, self.get_io_write_task(fileobj, data, offset) |
| 108 | ) |
| 109 | |
| 110 | def get_io_write_task(self, fileobj, data, offset): |
| 111 | """Get an IO write task for the requested set of data |