OriginalCompleteBeforeOriginalCompleteAfterBeforeAfterProjectCommitCompilationUnitLineNosNamesTemplateVariableToCodeBeforeRelevantImportsTemplateVariableToCodeAfterisRelevantisSafe
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))elasticsearch52e7b926a95fbc3ef1ad7f99abbf7e3d00264bf4org.elasticsearch.repositories.azure.AzureBlobStore
_1266
_2268
_1blobs
_2blobs
TCIVarblobs
  • java.util.Spliterators
  • reactor.core.publisher.Flux
  • java.util.stream.StreamSupport
TCIVarblobs
UsesTrue