Flux.fromIterable(blobs).flatMap(blob -> getDeleteTask(blob,blobContainerClient.getBlobAsyncClient(blob)),CONCURRENT_DELETES).then().block(); | Flux.fromStream(StreamSupport.stream(Spliterators.spliteratorUnknownSize(blobs,Spliterator.ORDERED),false)).flatMap(blob -> getDeleteTask(blob,blobContainerClient.getBlobAsyncClient(blob)),CONCURRENT_DELETES).then().block(); | blobs | StreamSupport.stream(Spliterators.spliteratorUnknownSize(blobs,Spliterator.ORDERED),false) | elasticsearch | 52e7b926a95fbc3ef1ad7f99abbf7e3d00264bf4 | org.elasticsearch.repositories.azure.AzureBlobStore | | | | - java.util.Spliterators
- java.util.stream.StreamSupport
| | Uses | True |