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(); | Flux.fromIterable(blobs) | Flux.fromStream(StreamSupport.stream(Spliterators.spliteratorUnknownSize(blobs,Spliterator.ORDERED),false)) | elasticsearch | 52e7b926a95fbc3ef1ad7f99abbf7e3d00264bf4 | org.elasticsearch.repositories.azure.AzureBlobStore | | | | - java.util.Spliterators
- reactor.core.publisher.Flux
- java.util.stream.StreamSupport
| | Uses | True |