DocumentProducer(IDocumentQueryClient, String, CosmosQueryRequestOptions, TriFunction, Function, PartitionKeyRange, String, Callable, Class, UUID, int, String, int, FeedRangeEpkImpl) | | 0% | | 0% | 2 | 2 | 22 | 22 | 1 | 1 |
lambda$splitProof$6(Throwable) | | 0% | | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
lambda$splitProof$5(Utils.ValueHolder) | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
createChildDocumentProducerOnSplit(PartitionKeyRange, String) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$new$1(Callable, Function, RxDocumentServiceRequest) | | 0% | | 0% | 2 | 2 | 11 | 11 | 1 | 1 |
produceAsync() | | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
createReplacingDocumentProducersOnSplit(List) | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
lambda$produceAsync$3(FeedResponse) | | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
lambda$new$0(DocumentClientRetryPolicy, RxDocumentServiceRequest, Function) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
getReplacementRanges(Range) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$produceAsync$2(String, Integer) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$produceAsync$4(FeedResponse) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
splitProof(Flux) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
produceOnSplit(Flux) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
static {...} | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isSplit(CosmosException) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |