BulkExecutor

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total425 of 4250%26 of 260%37371021022424
BulkExecutor(CosmosAsyncContainer, Flux, BulkProcessingOptions)750%n/a11181811
handleTransactionalBatchExecutionException(CosmosItemOperation, Exception, FluxSink)500%80%55111111
handleTransactionalBatchOperationResult(TransactionalBatchResponse, TransactionalBatchOperationResult, FluxSink)370%40%337711
executePartitionedGroup(GroupedFlux)330%n/a119911
execute()280%n/a11101011
executeOperations(List, String, FluxSink)260%20%226611
lambda$executePartitionKeyRangeServerBatchRequest$11(PartitionKeyRangeServerBatchRequest, FluxSink, Throwable)180%20%224411
lambda$handleTransactionalBatchExecutionException$13(FluxSink, CosmosItemOperation, Exception, ShouldRetryResult)160%20%224411
lambda$handleTransactionalBatchOperationResult$12(FluxSink, CosmosItemOperation, CosmosBulkItemResponse, ShouldRetryResult)160%20%224411
executePartitionKeyRangeServerBatchRequest(PartitionKeyRangeServerBatchRequest, FluxSink)130%n/a113311
lambda$execute$1(CosmosItemOperation)130%n/a113311
completeAllSinks()110%n/a114411
lambda$execute$5(CosmosBulkOperationResponse)110%40%333311
lambda$execute$2()110%20%224411
executeBatchRequest(PartitionKeyRangeServerBatchRequest)100%n/a112211
lambda$execute$4(CosmosItemOperation)100%n/a112211
lambda$executePartitionKeyRangeServerBatchRequest$9(FluxSink, TransactionalBatchResponse)90%n/a111111
lambda$execute$0(Throwable, Object)70%n/a112211
lambda$executePartitionKeyRangeServerBatchRequest$10(Exception, FluxSink, CosmosItemOperation)60%n/a111111
lambda$executePartitionKeyRangeServerBatchRequest$8(TransactionalBatchResponse, FluxSink, TransactionalBatchOperationResult)60%n/a111111
lambda$executePartitionedGroup$6(String, FluxSink, List)60%n/a111111
lambda$executeOperations$7(FluxSink, PartitionKeyRangeServerBatchRequest)50%n/a111111
lambda$execute$3(CosmosItemOperation, String)40%n/a111111
static {...}40%n/a111111