|
1269 | 1269 | .<span class="kw">await |
1270 | 1270 | </span>} |
1271 | 1271 |
|
1272 | | - <span class="kw">pub fn </span>add_slice(<span class="kw-2">&</span><span class="self">self</span>, data: <span class="kw">impl </span>AsRef<[u8]>) -> AddProgress { |
| 1272 | + <span class="kw">pub fn </span>add_slice(<span class="kw-2">&</span><span class="self">self</span>, data: <span class="kw">impl </span>AsRef<[u8]>) -> AddProgress<<span class="lifetime">'_</span>> { |
1273 | 1273 | <span class="kw">let </span>options = ImportBytesRequest { |
1274 | 1274 | data: Bytes::copy_from_slice(data.as_ref()), |
1275 | 1275 | format: <span class="kw">crate</span>::BlobFormat::Raw, |
|
1278 | 1278 | <span class="self">self</span>.add_bytes_impl(options) |
1279 | 1279 | } |
1280 | 1280 |
|
1281 | | - <span class="kw">pub fn </span>add_bytes(<span class="kw-2">&</span><span class="self">self</span>, data: <span class="kw">impl </span>Into<bytes::Bytes>) -> AddProgress { |
| 1281 | + <span class="kw">pub fn </span>add_bytes(<span class="kw-2">&</span><span class="self">self</span>, data: <span class="kw">impl </span>Into<bytes::Bytes>) -> AddProgress<<span class="lifetime">'_</span>> { |
1282 | 1282 | <span class="kw">let </span>options = ImportBytesRequest { |
1283 | 1283 | data: data.into(), |
1284 | 1284 | format: <span class="kw">crate</span>::BlobFormat::Raw, |
|
1287 | 1287 | <span class="self">self</span>.add_bytes_impl(options) |
1288 | 1288 | } |
1289 | 1289 |
|
1290 | | - <span class="kw">pub fn </span>add_bytes_with_opts(<span class="kw-2">&</span><span class="self">self</span>, options: <span class="kw">impl </span>Into<AddBytesOptions>) -> AddProgress { |
| 1290 | + <span class="kw">pub fn </span>add_bytes_with_opts(<span class="kw-2">&</span><span class="self">self</span>, options: <span class="kw">impl </span>Into<AddBytesOptions>) -> AddProgress<<span class="lifetime">'_</span>> { |
1291 | 1291 | <span class="kw">let </span>options = options.into(); |
1292 | 1292 | <span class="kw">let </span>request = ImportBytesRequest { |
1293 | 1293 | data: options.data, |
|
1297 | 1297 | <span class="self">self</span>.add_bytes_impl(request) |
1298 | 1298 | } |
1299 | 1299 |
|
1300 | | - <span class="kw">fn </span>add_bytes_impl(<span class="kw-2">&</span><span class="self">self</span>, options: ImportBytesRequest) -> AddProgress { |
| 1300 | + <span class="kw">fn </span>add_bytes_impl(<span class="kw-2">&</span><span class="self">self</span>, options: ImportBytesRequest) -> AddProgress<<span class="lifetime">'_</span>> { |
1301 | 1301 | <span class="macro">trace!</span>(<span class="string">"{options:?}"</span>); |
1302 | 1302 | <span class="kw">let </span>this = <span class="self">self</span>.clone(); |
1303 | 1303 | <span class="kw">let </span>stream = Gen::new(|co| <span class="kw">async move </span>{ |
|
1322 | 1322 | AddProgress::new(<span class="self">self</span>, stream) |
1323 | 1323 | } |
1324 | 1324 |
|
1325 | | - <span class="kw">pub fn </span>add_path_with_opts(<span class="kw-2">&</span><span class="self">self</span>, options: <span class="kw">impl </span>Into<AddPathOptions>) -> AddProgress { |
| 1325 | + <span class="kw">pub fn </span>add_path_with_opts(<span class="kw-2">&</span><span class="self">self</span>, options: <span class="kw">impl </span>Into<AddPathOptions>) -> AddProgress<<span class="lifetime">'_</span>> { |
1326 | 1326 | <span class="kw">let </span>options = options.into(); |
1327 | 1327 | <span class="self">self</span>.add_path_with_opts_impl(ImportPathRequest { |
1328 | 1328 | path: options.path, |
|
1332 | 1332 | }) |
1333 | 1333 | } |
1334 | 1334 |
|
1335 | | - <span class="kw">fn </span>add_path_with_opts_impl(<span class="kw-2">&</span><span class="self">self</span>, options: ImportPathRequest) -> AddProgress { |
| 1335 | + <span class="kw">fn </span>add_path_with_opts_impl(<span class="kw-2">&</span><span class="self">self</span>, options: ImportPathRequest) -> AddProgress<<span class="lifetime">'_</span>> { |
1336 | 1336 | <span class="macro">trace!</span>(<span class="string">"{:?}"</span>, options); |
1337 | 1337 | <span class="kw">let </span>client = <span class="self">self</span>.client.clone(); |
1338 | 1338 | <span class="kw">let </span>stream = Gen::new(|co| <span class="kw">async move </span>{ |
|
1357 | 1357 | AddProgress::new(<span class="self">self</span>, stream) |
1358 | 1358 | } |
1359 | 1359 |
|
1360 | | - <span class="kw">pub fn </span>add_path(<span class="kw-2">&</span><span class="self">self</span>, path: <span class="kw">impl </span>AsRef<Path>) -> AddProgress { |
| 1360 | + <span class="kw">pub fn </span>add_path(<span class="kw-2">&</span><span class="self">self</span>, path: <span class="kw">impl </span>AsRef<Path>) -> AddProgress<<span class="lifetime">'_</span>> { |
1361 | 1361 | <span class="self">self</span>.add_path_with_opts(AddPathOptions { |
1362 | 1362 | path: path.as_ref().to_owned(), |
1363 | 1363 | mode: ImportMode::Copy, |
|
1368 | 1368 | <span class="kw">pub async fn </span>add_stream( |
1369 | 1369 | <span class="kw-2">&</span><span class="self">self</span>, |
1370 | 1370 | data: <span class="kw">impl </span>Stream<Item = io::Result<Bytes>> + Send + Sync + <span class="lifetime">'static</span>, |
1371 | | - ) -> AddProgress { |
| 1371 | + ) -> AddProgress<<span class="lifetime">'_</span>> { |
1372 | 1372 | <span class="kw">let </span>inner = ImportByteStreamRequest { |
1373 | 1373 | format: <span class="kw">crate</span>::BlobFormat::Raw, |
1374 | 1374 | scope: Scope::default(), |
|
1663 | 1663 | } |
1664 | 1664 |
|
1665 | 1665 | <span class="kw">impl</span><<span class="lifetime">'a</span>> Batch<<span class="lifetime">'a</span>> { |
1666 | | - <span class="kw">pub fn </span>add_bytes(<span class="kw-2">&</span><span class="self">self</span>, data: <span class="kw">impl </span>Into<Bytes>) -> BatchAddProgress { |
| 1666 | + <span class="kw">pub fn </span>add_bytes(<span class="kw-2">&</span><span class="self">self</span>, data: <span class="kw">impl </span>Into<Bytes>) -> BatchAddProgress<<span class="lifetime">'_</span>> { |
1667 | 1667 | <span class="kw">let </span>options = ImportBytesRequest { |
1668 | 1668 | data: data.into(), |
1669 | 1669 | format: <span class="kw">crate</span>::BlobFormat::Raw, |
|
1672 | 1672 | BatchAddProgress(<span class="self">self</span>.blobs.add_bytes_impl(options)) |
1673 | 1673 | } |
1674 | 1674 |
|
1675 | | - <span class="kw">pub fn </span>add_bytes_with_opts(<span class="kw-2">&</span><span class="self">self</span>, options: <span class="kw">impl </span>Into<AddBytesOptions>) -> BatchAddProgress { |
| 1675 | + <span class="kw">pub fn </span>add_bytes_with_opts(<span class="kw-2">&</span><span class="self">self</span>, options: <span class="kw">impl </span>Into<AddBytesOptions>) -> BatchAddProgress<<span class="lifetime">'_</span>> { |
1676 | 1676 | <span class="kw">let </span>options = options.into(); |
1677 | 1677 | BatchAddProgress(<span class="self">self</span>.blobs.add_bytes_impl(ImportBytesRequest { |
1678 | 1678 | data: options.data, |
|
1681 | 1681 | })) |
1682 | 1682 | } |
1683 | 1683 |
|
1684 | | - <span class="kw">pub fn </span>add_slice(<span class="kw-2">&</span><span class="self">self</span>, data: <span class="kw">impl </span>AsRef<[u8]>) -> BatchAddProgress { |
| 1684 | + <span class="kw">pub fn </span>add_slice(<span class="kw-2">&</span><span class="self">self</span>, data: <span class="kw">impl </span>AsRef<[u8]>) -> BatchAddProgress<<span class="lifetime">'_</span>> { |
1685 | 1685 | <span class="kw">let </span>options = ImportBytesRequest { |
1686 | 1686 | data: Bytes::copy_from_slice(data.as_ref()), |
1687 | 1687 | format: <span class="kw">crate</span>::BlobFormat::Raw, |
|
1690 | 1690 | BatchAddProgress(<span class="self">self</span>.blobs.add_bytes_impl(options)) |
1691 | 1691 | } |
1692 | 1692 |
|
1693 | | - <span class="kw">pub fn </span>add_path_with_opts(<span class="kw-2">&</span><span class="self">self</span>, options: <span class="kw">impl </span>Into<AddPathOptions>) -> BatchAddProgress { |
| 1693 | + <span class="kw">pub fn </span>add_path_with_opts(<span class="kw-2">&</span><span class="self">self</span>, options: <span class="kw">impl </span>Into<AddPathOptions>) -> BatchAddProgress<<span class="lifetime">'_</span>> { |
1694 | 1694 | <span class="kw">let </span>options = options.into(); |
1695 | 1695 | BatchAddProgress(<span class="self">self</span>.blobs.add_path_with_opts_impl(ImportPathRequest { |
1696 | 1696 | path: options.path, |
|
0 commit comments