Home
last modified time | relevance | path

Searched refs:process_substream_block (Results 1 – 25 of 36) sorted by relevance

12

/dports/devel/py-azure-multiapi-storage/azure-multiapi-storage-0.6.2/azure/multiapi/storagev2/blob/v2020_04_08/_shared/
H A Duploads_async.py119 asyncio.ensure_future(uploader.process_substream_block(u))
122 …range_ids = await _parallel_uploads(uploader.process_substream_block, upload_tasks, running_future…
126 range_ids.append(await uploader.process_substream_block(block))
229 async def process_substream_block(self, block_data): member in _ChunkUploader
H A Duploads.py118 executor.submit(with_current_context(uploader.process_substream_block), u)
121 …range_ids = _parallel_uploads(executor, uploader.process_substream_block, upload_tasks, running_fu…
123 range_ids = [uploader.process_substream_block(b) for b in uploader.get_substream_blocks()]
226 def process_substream_block(self, block_data): member in _ChunkUploader
/dports/devel/py-azure-multiapi-storage/azure-multiapi-storage-0.6.2/azure/multiapi/storagev2/fileshare/v2020_02_10/_shared/
H A Duploads_async.py119 asyncio.ensure_future(uploader.process_substream_block(u))
122 …range_ids = await _parallel_uploads(uploader.process_substream_block, upload_tasks, running_future…
126 range_ids.append(await uploader.process_substream_block(block))
229 async def process_substream_block(self, block_data): member in _ChunkUploader
H A Duploads.py118 executor.submit(with_current_context(uploader.process_substream_block), u)
121 …range_ids = _parallel_uploads(executor, uploader.process_substream_block, upload_tasks, running_fu…
123 range_ids = [uploader.process_substream_block(b) for b in uploader.get_substream_blocks()]
226 def process_substream_block(self, block_data): member in _ChunkUploader
/dports/devel/py-azure-multiapi-storage/azure-multiapi-storage-0.6.2/azure/multiapi/storagev2/blob/v2020_02_10/_shared/
H A Duploads_async.py119 asyncio.ensure_future(uploader.process_substream_block(u))
122 …range_ids = await _parallel_uploads(uploader.process_substream_block, upload_tasks, running_future…
126 range_ids.append(await uploader.process_substream_block(block))
229 async def process_substream_block(self, block_data): member in _ChunkUploader
H A Duploads.py118 executor.submit(with_current_context(uploader.process_substream_block), u)
121 …range_ids = _parallel_uploads(executor, uploader.process_substream_block, upload_tasks, running_fu…
123 range_ids = [uploader.process_substream_block(b) for b in uploader.get_substream_blocks()]
226 def process_substream_block(self, block_data): member in _ChunkUploader
/dports/devel/py-azure-multiapi-storage/azure-multiapi-storage-0.6.2/azure/multiapi/storagev2/filedatalake/v2020_02_10/_shared/
H A Duploads_async.py119 asyncio.ensure_future(uploader.process_substream_block(u))
122 …range_ids = await _parallel_uploads(uploader.process_substream_block, upload_tasks, running_future…
126 range_ids.append(await uploader.process_substream_block(block))
229 async def process_substream_block(self, block_data): member in _ChunkUploader
/dports/devel/py-azure-multiapi-storage/azure-multiapi-storage-0.6.2/azure/multiapi/storagev2/fileshare/v2019_12_12/_shared/
H A Duploads_async.py119 asyncio.ensure_future(uploader.process_substream_block(u))
122 …range_ids = await _parallel_uploads(uploader.process_substream_block, upload_tasks, running_future…
126 range_ids.append(await uploader.process_substream_block(block))
229 async def process_substream_block(self, block_data): member in _ChunkUploader
H A Duploads.py118 executor.submit(with_current_context(uploader.process_substream_block), u)
121 …range_ids = _parallel_uploads(executor, uploader.process_substream_block, upload_tasks, running_fu…
123 range_ids = [uploader.process_substream_block(b) for b in uploader.get_substream_blocks()]
226 def process_substream_block(self, block_data): member in _ChunkUploader
/dports/devel/py-azure-multiapi-storage/azure-multiapi-storage-0.6.2/azure/multiapi/storagev2/filedatalake/v2018_11_09/_shared/
H A Duploads_async.py119 asyncio.ensure_future(uploader.process_substream_block(u))
122 …range_ids = await _parallel_uploads(uploader.process_substream_block, upload_tasks, running_future…
126 range_ids.append(await uploader.process_substream_block(block))
229 async def process_substream_block(self, block_data): member in _ChunkUploader
H A Duploads.py118 executor.submit(with_current_context(uploader.process_substream_block), u)
121 …range_ids = _parallel_uploads(executor, uploader.process_substream_block, upload_tasks, running_fu…
123 range_ids = [uploader.process_substream_block(b) for b in uploader.get_substream_blocks()]
226 def process_substream_block(self, block_data): member in _ChunkUploader
/dports/devel/py-azure-multiapi-storage/azure-multiapi-storage-0.6.2/azure/multiapi/storagev2/fileshare/v2020_04_08/_shared/
H A Duploads_async.py119 asyncio.ensure_future(uploader.process_substream_block(u))
122 …range_ids = await _parallel_uploads(uploader.process_substream_block, upload_tasks, running_future…
126 range_ids.append(await uploader.process_substream_block(block))
229 async def process_substream_block(self, block_data): member in _ChunkUploader
H A Duploads.py118 executor.submit(with_current_context(uploader.process_substream_block), u)
121 …range_ids = _parallel_uploads(executor, uploader.process_substream_block, upload_tasks, running_fu…
123 range_ids = [uploader.process_substream_block(b) for b in uploader.get_substream_blocks()]
226 def process_substream_block(self, block_data): member in _ChunkUploader
/dports/devel/py-azure-multiapi-storage/azure-multiapi-storage-0.6.2/azure/multiapi/storagev2/queue/v2018_03_28/_shared/
H A Duploads_async.py119 asyncio.ensure_future(uploader.process_substream_block(u))
122 …range_ids = await _parallel_uploads(uploader.process_substream_block, upload_tasks, running_future…
126 range_ids.append(await uploader.process_substream_block(block))
229 async def process_substream_block(self, block_data): member in _ChunkUploader
H A Duploads.py118 executor.submit(with_current_context(uploader.process_substream_block), u)
121 …range_ids = _parallel_uploads(executor, uploader.process_substream_block, upload_tasks, running_fu…
123 range_ids = [uploader.process_substream_block(b) for b in uploader.get_substream_blocks()]
226 def process_substream_block(self, block_data): member in _ChunkUploader
/dports/devel/py-azure-multiapi-storage/azure-multiapi-storage-0.6.2/azure/multiapi/storagev2/blob/v2019_02_02/_shared/
H A Duploads_async.py119 asyncio.ensure_future(uploader.process_substream_block(u))
122 …range_ids = await _parallel_uploads(uploader.process_substream_block, upload_tasks, running_future…
126 range_ids.append(await uploader.process_substream_block(block))
229 async def process_substream_block(self, block_data): member in _ChunkUploader
H A Duploads.py118 executor.submit(with_current_context(uploader.process_substream_block), u)
121 …range_ids = _parallel_uploads(executor, uploader.process_substream_block, upload_tasks, running_fu…
123 range_ids = [uploader.process_substream_block(b) for b in uploader.get_substream_blocks()]
226 def process_substream_block(self, block_data): member in _ChunkUploader
/dports/devel/py-azure-multiapi-storage/azure-multiapi-storage-0.6.2/azure/multiapi/storagev2/blob/v2019_07_07/_shared/
H A Duploads_async.py119 asyncio.ensure_future(uploader.process_substream_block(u))
122 …range_ids = await _parallel_uploads(uploader.process_substream_block, upload_tasks, running_future…
126 range_ids.append(await uploader.process_substream_block(block))
229 async def process_substream_block(self, block_data): member in _ChunkUploader
/dports/devel/py-azure-multiapi-storage/azure-multiapi-storage-0.6.2/azure/multiapi/storagev2/blob/v2019_12_12/_shared/
H A Duploads_async.py119 asyncio.ensure_future(uploader.process_substream_block(u))
122 …range_ids = await _parallel_uploads(uploader.process_substream_block, upload_tasks, running_future…
126 range_ids.append(await uploader.process_substream_block(block))
229 async def process_substream_block(self, block_data): member in _ChunkUploader
H A Duploads.py118 executor.submit(with_current_context(uploader.process_substream_block), u)
121 …range_ids = _parallel_uploads(executor, uploader.process_substream_block, upload_tasks, running_fu…
123 range_ids = [uploader.process_substream_block(b) for b in uploader.get_substream_blocks()]
226 def process_substream_block(self, block_data): member in _ChunkUploader
/dports/devel/py-azure-multiapi-storage/azure-multiapi-storage-0.6.2/azure/multiapi/storagev2/filedatalake/v2019_12_12/_shared/
H A Duploads_async.py119 asyncio.ensure_future(uploader.process_substream_block(u))
122 …range_ids = await _parallel_uploads(uploader.process_substream_block, upload_tasks, running_future…
126 range_ids.append(await uploader.process_substream_block(block))
229 async def process_substream_block(self, block_data): member in _ChunkUploader
H A Duploads.py118 executor.submit(with_current_context(uploader.process_substream_block), u)
121 …range_ids = _parallel_uploads(executor, uploader.process_substream_block, upload_tasks, running_fu…
123 range_ids = [uploader.process_substream_block(b) for b in uploader.get_substream_blocks()]
226 def process_substream_block(self, block_data): member in _ChunkUploader
/dports/devel/py-azure-multiapi-storage/azure-multiapi-storage-0.6.2/azure/multiapi/storagev2/fileshare/v2019_02_02/_shared/
H A Duploads_async.py119 asyncio.ensure_future(uploader.process_substream_block(u))
122 …range_ids = await _parallel_uploads(uploader.process_substream_block, upload_tasks, running_future…
126 range_ids.append(await uploader.process_substream_block(block))
229 async def process_substream_block(self, block_data): member in _ChunkUploader
H A Duploads.py118 executor.submit(with_current_context(uploader.process_substream_block), u)
121 …range_ids = _parallel_uploads(executor, uploader.process_substream_block, upload_tasks, running_fu…
123 range_ids = [uploader.process_substream_block(b) for b in uploader.get_substream_blocks()]
226 def process_substream_block(self, block_data): member in _ChunkUploader
/dports/devel/py-azure-multiapi-storage/azure-multiapi-storage-0.6.2/azure/multiapi/storagev2/fileshare/v2019_07_07/_shared/
H A Duploads_async.py119 asyncio.ensure_future(uploader.process_substream_block(u))
122 …range_ids = await _parallel_uploads(uploader.process_substream_block, upload_tasks, running_future…
126 range_ids.append(await uploader.process_substream_block(block))
229 async def process_substream_block(self, block_data): member in _ChunkUploader

12