Flux.java |  | 0% |  | 0% | 611 | 611 | 885 | 885 | 483 | 483 | 6 | 6 |
FluxWindowTimeout.java |  | 0% |  | 0% | 413 | 413 | 955 | 955 | 88 | 88 | 5 | 5 |
Operators.java |  | 0% |  | 0% | 467 | 467 | 931 | 931 | 208 | 208 | 14 | 14 |
Mono.java |  | 0% |  | 0% | 347 | 347 | 484 | 484 | 259 | 259 | 3 | 3 |
FluxReplay.java |  | 0% |  | 0% | 329 | 329 | 768 | 768 | 113 | 113 | 8 | 8 |
FluxFlatMap.java |  | 0% |  | 0% | 230 | 230 | 560 | 560 | 50 | 50 | 4 | 4 |
FluxPublishOn.java |  | 0% |  | 0% | 196 | 196 | 553 | 553 | 50 | 50 | 3 | 3 |
FluxZip.java |  | 0% |  | 0% | 192 | 192 | 490 | 490 | 64 | 64 | 7 | 7 |
FluxSwitchOnFirst.java |  | 0% |  | 0% | 209 | 209 | 414 | 414 | 61 | 61 | 6 | 6 |
FluxSwitchMapNoPrefetch.java |  | 0% |  | 0% | 173 | 173 | 399 | 399 | 45 | 45 | 3 | 3 |
FluxCreate.java |  | 0% |  | 0% | 205 | 205 | 417 | 417 | 90 | 90 | 12 | 12 |
FluxPeekFuseable.java |  | 0% |  | 0% | 149 | 149 | 453 | 453 | 52 | 52 | 4 | 4 |
FluxConcatMap.java |  | 0% |  | 0% | 146 | 146 | 367 | 367 | 43 | 43 | 6 | 6 |
FluxWindowPredicate.java |  | 0% |  | 0% | 168 | 168 | 409 | 409 | 51 | 51 | 3 | 3 |
FluxPublishMulticast.java |  | 0% |  | 0% | 148 | 148 | 370 | 370 | 55 | 55 | 5 | 5 |
FluxFlattenIterable.java |  | 0% |  | 0% | 111 | 111 | 385 | 385 | 23 | 23 | 2 | 2 |
FluxWindow.java |  | 0% |  | 0% | 139 | 139 | 327 | 327 | 45 | 45 | 4 | 4 |
FluxGroupBy.java |  | 0% |  | 0% | 147 | 147 | 366 | 366 | 48 | 48 | 3 | 3 |
FluxHandleFuseable.java |  | 0% |  | 0% | 130 | 130 | 377 | 377 | 45 | 45 | 3 | 3 |
FluxOnAssembly.java |  | 0% |  | 0% | 119 | 119 | 256 | 256 | 63 | 63 | 9 | 9 |
FluxPublish.java |  | 0% |  | 0% | 139 | 139 | 287 | 287 | 36 | 36 | 4 | 4 |
FluxBufferWhen.java |  | 0% |  | 0% | 107 | 107 | 285 | 285 | 39 | 39 | 4 | 4 |
EmitterProcessor.java |  | 0% |  | 0% | 136 | 136 | 270 | 270 | 42 | 42 | 3 | 3 |
FluxCombineLatest.java |  | 0% |  | 0% | 103 | 103 | 288 | 288 | 40 | 40 | 4 | 4 |
SinkManyEmitterProcessor.java |  | 0% |  | 0% | 133 | 133 | 268 | 268 | 36 | 36 | 3 | 3 |
ParallelFlux.java |  | 0% |  | 0% | 101 | 101 | 171 | 171 | 80 | 80 | 1 | 1 |
FluxMergeComparing.java |  | 0% |  | 0% | 93 | 93 | 226 | 226 | 26 | 26 | 3 | 3 |
FluxGroupJoin.java |  | 0% |  | 0% | 84 | 84 | 249 | 249 | 37 | 37 | 4 | 4 |
FluxBuffer.java |  | 0% |  | 0% | 96 | 96 | 236 | 236 | 35 | 35 | 4 | 4 |
FluxMergeSequential.java |  | 0% |  | 0% | 112 | 112 | 262 | 262 | 34 | 34 | 3 | 3 |
FluxIterable.java |  | 0% |  | 0% | 110 | 110 | 314 | 314 | 35 | 35 | 3 | 3 |
MonoZip.java |  | 0% |  | 0% | 107 | 107 | 221 | 221 | 36 | 36 | 3 | 3 |
FluxDistinct.java |  | 0% |  | 0% | 78 | 78 | 245 | 245 | 38 | 38 | 4 | 4 |
SignalLogger.java |  | 0% |  | 0% | 101 | 101 | 142 | 142 | 26 | 26 | 1 | 1 |
ParallelSource.java |  | 0% |  | 0% | 86 | 86 | 241 | 241 | 24 | 24 | 3 | 3 |
MonoDelayUntil.java |  | 0% |  | 0% | 109 | 109 | 242 | 242 | 39 | 39 | 3 | 3 |
NextProcessor.java |  | 0% |  | 0% | 112 | 112 | 228 | 228 | 33 | 33 | 2 | 2 |
FluxFilterWhen.java |  | 0% |  | 0% | 94 | 94 | 234 | 234 | 30 | 30 | 3 | 3 |
FluxConcatArray.java |  | 0% |  | 0% | 89 | 89 | 230 | 230 | 32 | 32 | 3 | 3 |
FluxSwitchMap.java |  | 0% |  | 0% | 100 | 100 | 233 | 233 | 36 | 36 | 3 | 3 |
FluxUsingWhen.java |  | 0% |  | 0% | 90 | 90 | 199 | 199 | 48 | 48 | 7 | 7 |
FluxJoin.java |  | 0% |  | 0% | 53 | 53 | 213 | 213 | 17 | 17 | 2 | 2 |
FluxTake.java |  | 0% |  | 0% | 99 | 99 | 220 | 220 | 40 | 40 | 4 | 4 |
FluxUsing.java |  | 0% |  | 0% | 103 | 103 | 205 | 205 | 52 | 52 | 4 | 4 |
FluxHandle.java |  | 0% |  | 0% | 86 | 86 | 226 | 226 | 35 | 35 | 3 | 3 |
FluxExpand.java |  | 0% |  | 0% | 88 | 88 | 227 | 227 | 35 | 35 | 4 | 4 |
UnicastProcessor.java |  | 0% |  | 0% | 104 | 104 | 221 | 221 | 44 | 44 | 1 | 1 |
Hooks.java |  | 0% |  | 0% | 61 | 61 | 208 | 208 | 42 | 42 | 1 | 1 |
MonoWhen.java |  | 0% |  | 0% | 93 | 93 | 177 | 177 | 35 | 35 | 3 | 3 |
ParallelMergeSequential.java |  | 0% |  | 0% | 93 | 93 | 196 | 196 | 29 | 29 | 3 | 3 |
FluxWindowWhen.java |  | 0% |  | 0% | 80 | 80 | 212 | 212 | 35 | 35 | 5 | 5 |
FluxBufferPredicate.java |  | 0% |  | 0% | 79 | 79 | 177 | 177 | 30 | 30 | 4 | 4 |
FluxFilterFuseable.java |  | 0% |  | 0% | 79 | 79 | 207 | 207 | 33 | 33 | 3 | 3 |
Traces.java |  | 0% |  | 0% | 73 | 73 | 147 | 147 | 25 | 25 | 6 | 6 |
FluxBufferTimeout.java |  | 0% |  | 0% | 67 | 67 | 166 | 166 | 21 | 21 | 2 | 2 |
SinkManyUnicast.java |  | 0% |  | 0% | 87 | 87 | 187 | 187 | 30 | 30 | 1 | 1 |
MonoSequenceEqual.java |  | 0% |  | 0% | 70 | 70 | 167 | 167 | 22 | 22 | 3 | 3 |
MonoCacheInvalidateWhen.java |  | 0% |  | 0% | 76 | 76 | 159 | 159 | 32 | 32 | 4 | 4 |
FluxOnBackpressureBuffer.java |  | 0% |  | 0% | 81 | 81 | 178 | 178 | 23 | 23 | 2 | 2 |
FluxWindowBoundary.java |  | 0% |  | 0% | 69 | 69 | 179 | 179 | 30 | 30 | 3 | 3 |
FluxArray.java |  | 0% |  | 0% | 75 | 75 | 165 | 165 | 28 | 28 | 3 | 3 |
MonoCacheTime.java |  | 0% |  | 0% | 66 | 66 | 163 | 163 | 30 | 30 | 3 | 3 |
FluxTimeout.java |  | 0% |  | 0% | 71 | 71 | 166 | 166 | 39 | 39 | 5 | 5 |
SinkManyReplayProcessor.java |  | 0% |  | 0% | 84 | 84 | 156 | 156 | 52 | 52 | 2 | 2 |
FluxFirstWithValue.java |  | 0% |  | 0% | 55 | 55 | 154 | 154 | 22 | 22 | 3 | 3 |
ReplayProcessor.java |  | 0% |  | 0% | 84 | 84 | 155 | 155 | 54 | 54 | 2 | 2 |
FluxOnBackpressureBufferTimeout.java |  | 0% |  | 0% | 63 | 63 | 173 | 173 | 19 | 19 | 2 | 2 |
FluxRange.java |  | 0% |  | 0% | 74 | 74 | 154 | 154 | 27 | 27 | 3 | 3 |
SinkManyBestEffort.java |  | 0% |  | 0% | 76 | 76 | 157 | 157 | 26 | 26 | 2 | 2 |
ParallelMergeReduce.java |  | 0% |  | 0% | 74 | 74 | 148 | 148 | 31 | 31 | 4 | 4 |
MonoPeekTerminal.java |  | 0% |  | 0% | 65 | 65 | 154 | 154 | 20 | 20 | 2 | 2 |
FluxSampleTimeout.java |  | 0% |  | 0% | 66 | 66 | 157 | 157 | 29 | 29 | 3 | 3 |
FluxMetrics.java |  | 0% |  | 0% | 35 | 35 | 129 | 129 | 22 | 22 | 2 | 2 |
MonoPublishMulticast.java |  | 0% |  | 0% | 68 | 68 | 160 | 160 | 23 | 23 | 3 | 3 |
FluxGenerate.java |  | 0% |  | 0% | 66 | 66 | 167 | 167 | 28 | 28 | 2 | 2 |
ParallelMergeSort.java |  | 0% |  | 0% | 67 | 67 | 157 | 157 | 24 | 24 | 3 | 3 |
MonoCacheInvalidateIf.java |  | 0% |  | 0% | 65 | 65 | 143 | 143 | 26 | 26 | 5 | 5 |
FluxOnBackpressureBufferStrategy.java |  | 0% |  | 0% | 67 | 67 | 167 | 167 | 18 | 18 | 2 | 2 |
FluxConcatMapNoPrefetch.java |  | 0% |  | 0% | 58 | 58 | 134 | 134 | 19 | 19 | 3 | 3 |
FluxMapFuseable.java |  | 0% |  | 0% | 63 | 63 | 148 | 148 | 32 | 32 | 3 | 3 |
MonoUsing.java |  | 0% |  | 0% | 60 | 60 | 139 | 139 | 19 | 19 | 2 | 2 |
MonoFilterWhen.java |  | 0% |  | 0% | 74 | 74 | 136 | 136 | 30 | 30 | 3 | 3 |
FluxFirstWithSignal.java |  | 0% |  | 0% | 54 | 54 | 139 | 139 | 20 | 20 | 3 | 3 |
MonoIgnoreThen.java |  | 0% |  | 0% | 63 | 63 | 154 | 154 | 23 | 23 | 2 | 2 |
MonoCreate.java |  | 0% |  | 0% | 70 | 70 | 142 | 142 | 21 | 21 | 2 | 2 |
SerializedSubscriber.java |  | 0% |  | 0% | 54 | 54 | 146 | 146 | 14 | 14 | 2 | 2 |
FluxBufferBoundary.java |  | 0% |  | 0% | 56 | 56 | 141 | 141 | 25 | 25 | 3 | 3 |
FluxDoOnEach.java |  | 0% |  | 0% | 64 | 64 | 137 | 137 | 31 | 31 | 5 | 5 |
FluxIndexFuseable.java |  | 0% |  | 0% | 57 | 57 | 136 | 136 | 32 | 32 | 3 | 3 |
ParallelThen.java |  | 0% |  | 0% | 70 | 70 | 107 | 107 | 31 | 31 | 3 | 3 |
FluxDistinctUntilChanged.java |  | 0% |  | 0% | 45 | 45 | 129 | 129 | 23 | 23 | 3 | 3 |
DirectProcessor.java |  | 0% |  | 0% | 55 | 55 | 117 | 117 | 24 | 24 | 1 | 1 |
MonoFlatMap.java |  | 0% |  | 0% | 61 | 61 | 122 | 122 | 31 | 31 | 3 | 3 |
FluxFilter.java |  | 0% |  | 0% | 49 | 49 | 130 | 130 | 23 | 23 | 3 | 3 |
MonoDelay.java |  | 0% |  | 0% | 69 | 69 | 107 | 107 | 22 | 22 | 2 | 2 |
FluxMapSignal.java |  | 0% |  | 0% | 46 | 46 | 106 | 106 | 19 | 19 | 2 | 2 |
FluxRefCountGrace.java |  | 0% |  | 0% | 57 | 57 | 117 | 117 | 27 | 27 | 3 | 3 |
FluxSubscribeOnCallable.java |  | 0% |  | 0% | 60 | 60 | 122 | 122 | 18 | 18 | 2 | 2 |
FluxMap.java |  | 0% |  | 0% | 45 | 45 | 109 | 109 | 22 | 22 | 3 | 3 |
FluxTap.java |  | 0% |  | 0% | 30 | 30 | 141 | 141 | 19 | 19 | 3 | 3 |
FluxPeek.java |  | 0% |  | 0% | 45 | 45 | 129 | 129 | 22 | 22 | 2 | 2 |
QueueDrainSubscriber.java |  | 0% |  | 0% | 62 | 62 | 116 | 116 | 23 | 23 | 6 | 6 |
FluxIndex.java |  | 0% |  | 0% | 44 | 44 | 109 | 109 | 25 | 25 | 4 | 4 |
SinksSpecs.java |  | 0% |  | 0% | 66 | 66 | 97 | 97 | 59 | 59 | 5 | 5 |
FluxSample.java |  | 0% |  | 0% | 57 | 57 | 111 | 111 | 27 | 27 | 3 | 3 |
FluxRefCount.java |  | 0% |  | 0% | 52 | 52 | 101 | 101 | 26 | 26 | 3 | 3 |
FluxSubscribeOnValue.java |  | 0% |  | 0% | 62 | 62 | 103 | 103 | 26 | 26 | 3 | 3 |
BlockingIterable.java |  | 0% |  | 0% | 41 | 41 | 99 | 99 | 18 | 18 | 2 | 2 |
FluxRetryWhen.java |  | 0% |  | 0% | 47 | 47 | 102 | 102 | 32 | 32 | 3 | 3 |
DrainUtils.java |  | 0% |  | 0% | 38 | 38 | 97 | 97 | 7 | 7 | 1 | 1 |
FluxWithLatestFrom.java |  | 0% |  | 0% | 51 | 51 | 114 | 114 | 26 | 26 | 3 | 3 |
FluxOnBackpressureLatest.java |  | 0% |  | 0% | 51 | 51 | 100 | 100 | 16 | 16 | 2 | 2 |
SinkEmptyMulticast.java |  | 0% |  | 0% | 46 | 46 | 97 | 97 | 21 | 21 | 2 | 2 |
MonoReduce.java |  | 0% |  | 0% | 40 | 40 | 99 | 99 | 18 | 18 | 2 | 2 |
FluxTapFuseable.java |  | 0% |  | 0% | 34 | 34 | 106 | 106 | 15 | 15 | 3 | 3 |
FluxSampleFirst.java |  | 0% |  | 0% | 48 | 48 | 100 | 100 | 26 | 26 | 3 | 3 |
FluxOnErrorReturn.java |  | 0% |  | 0% | 45 | 45 | 83 | 83 | 14 | 14 | 2 | 2 |
MonoDelayElement.java |  | 0% |  | 0% | 44 | 44 | 88 | 88 | 19 | 19 | 2 | 2 |
MonoUsingWhen.java |  | 0% |  | 0% | 32 | 32 | 84 | 84 | 17 | 17 | 3 | 3 |
FluxScanSeed.java |  | 0% |  | 0% | 35 | 35 | 93 | 93 | 17 | 17 | 3 | 3 |
MonoFlatMapMany.java |  | 0% |  | 0% | 41 | 41 | 91 | 91 | 22 | 22 | 3 | 3 |
FluxTakeUntilOther.java |  | 0% |  | 0% | 51 | 51 | 92 | 92 | 25 | 25 | 3 | 3 |
ParallelReduceSeed.java |  | 0% |  | 0% | 33 | 33 | 85 | 85 | 13 | 13 | 2 | 2 |
FluxSubscribeOn.java |  | 0% |  | 0% | 37 | 37 | 79 | 79 | 16 | 16 | 2 | 2 |
FluxSkipUntilOther.java |  | 0% |  | 0% | 42 | 42 | 87 | 87 | 22 | 22 | 3 | 3 |
FluxMaterialize.java |  | 0% |  | 0% | 45 | 45 | 69 | 69 | 21 | 21 | 2 | 2 |
FluxTimed.java |  | 0% |  | 0% | 36 | 36 | 66 | 66 | 21 | 21 | 3 | 3 |
FluxRepeatWhen.java |  | 0% |  | 0% | 39 | 39 | 85 | 85 | 27 | 27 | 3 | 3 |
SinkManyUnicastNoBackpressure.java |  | 0% |  | 0% | 41 | 41 | 68 | 68 | 15 | 15 | 2 | 2 |
ParallelCollect.java |  | 0% |  | 0% | 30 | 30 | 79 | 79 | 13 | 13 | 2 | 2 |
FluxDelaySequence.java |  | 0% |  | 0% | 35 | 35 | 67 | 67 | 19 | 19 | 4 | 4 |
MonoSubscribeOn.java |  | 0% |  | 0% | 33 | 33 | 75 | 75 | 16 | 16 | 2 | 2 |
MonoMetricsFuseable.java |  | 0% |  | 0% | 31 | 31 | 62 | 62 | 13 | 13 | 2 | 2 |
MonoStreamCollector.java |  | 0% |  | 0% | 22 | 22 | 81 | 81 | 11 | 11 | 2 | 2 |
MonoTakeLastOne.java |  | 0% |  | 0% | 30 | 30 | 75 | 75 | 12 | 12 | 2 | 2 |
BlockingOptionalMonoSubscriber.java |  | 0% |  | 0% | 32 | 32 | 66 | 66 | 12 | 12 | 1 | 1 |
FluxMetricsFuseable.java |  | 0% |  | 0% | 25 | 25 | 54 | 54 | 11 | 11 | 2 | 2 |
StateLogger.java |  | 0% |  | 0% | 12 | 12 | 42 | 42 | 6 | 6 | 1 | 1 |
MonoFirstWithValue.java |  | 0% |  | 0% | 15 | 15 | 76 | 76 | 6 | 6 | 1 | 1 |
StrictSubscriber.java |  | 0% |  | 0% | 31 | 31 | 68 | 68 | 10 | 10 | 1 | 1 |
FluxZipIterable.java |  | 0% |  | 0% | 22 | 22 | 68 | 68 | 12 | 12 | 2 | 2 |
FluxTakeLast.java |  | 0% |  | 0% | 38 | 38 | 65 | 65 | 24 | 24 | 3 | 3 |
MonoPublishOn.java |  | 0% |  | 0% | 32 | 32 | 64 | 64 | 15 | 15 | 2 | 2 |
FluxSkipUntil.java |  | 0% |  | 0% | 26 | 26 | 70 | 70 | 13 | 13 | 2 | 2 |
FluxSkipWhile.java |  | 0% |  | 0% | 26 | 26 | 70 | 70 | 13 | 13 | 2 | 2 |
FluxLimitRequest.java |  | 0% |  | 0% | 30 | 30 | 64 | 64 | 14 | 14 | 2 | 2 |
LambdaMonoSubscriber.java |  | 0% |  | 0% | 30 | 30 | 73 | 73 | 12 | 12 | 1 | 1 |
MonoCollect.java |  | 0% |  | 0% | 20 | 20 | 68 | 68 | 11 | 11 | 2 | 2 |
BlockingSingleSubscriber.java |  | 0% |  | 0% | 27 | 27 | 55 | 55 | 9 | 9 | 1 | 1 |
FluxOnBackpressureDrop.java |  | 0% |  | 0% | 30 | 30 | 65 | 65 | 17 | 17 | 2 | 2 |
SinkOneMulticast.java |  | 0% |  | 0% | 28 | 28 | 52 | 52 | 11 | 11 | 2 | 2 |
MonoReduceSeed.java |  | 0% |  | 0% | 20 | 20 | 60 | 60 | 10 | 10 | 2 | 2 |
MonoSingle.java |  | 0% |  | 0% | 28 | 28 | 65 | 65 | 13 | 13 | 2 | 2 |
ParallelGroup.java |  | 0% |  | 0% | 31 | 31 | 60 | 60 | 15 | 15 | 2 | 2 |
FluxDefaultIfEmpty.java |  | 0% |  | 0% | 33 | 33 | 58 | 58 | 12 | 12 | 2 | 2 |
MonoElementAt.java |  | 0% |  | 0% | 19 | 19 | 52 | 52 | 10 | 10 | 2 | 2 |
ImmutableSignal.java |  | 0% |  | 0% | 29 | 29 | 46 | 46 | 11 | 11 | 1 | 1 |
MonoMetrics.java |  | 0% |  | 0% | 19 | 19 | 53 | 53 | 12 | 12 | 2 | 2 |
FluxDelaySubscription.java |  | 0% |  | 0% | 32 | 32 | 62 | 62 | 21 | 21 | 3 | 3 |
FluxInterval.java |  | 0% |  | 0% | 22 | 22 | 47 | 47 | 10 | 10 | 2 | 2 |
LambdaSubscriber.java |  | 0% |  | 0% | 27 | 27 | 59 | 59 | 11 | 11 | 1 | 1 |
MonoFirstWithSignal.java |  | 0% |  | 0% | 13 | 13 | 63 | 63 | 5 | 5 | 1 | 1 |
MonoName.java |  | 0% |  | 0% | 17 | 17 | 42 | 42 | 5 | 5 | 1 | 1 |
FluxName.java |  | 0% |  | 0% | 17 | 17 | 42 | 42 | 5 | 5 | 1 | 1 |
OnNextFailureStrategy.java |  | 0% |  | 0% | 30 | 30 | 50 | 50 | 20 | 20 | 5 | 5 |
ParallelDoOnEach.java |  | 0% |  | 0% | 26 | 26 | 38 | 38 | 17 | 17 | 2 | 2 |
Sinks.java |  | 0% |  | 0% | 24 | 24 | 32 | 32 | 18 | 18 | 5 | 5 |
FluxContextWrite.java |  | 0% |  | 0% | 32 | 32 | 52 | 52 | 19 | 19 | 2 | 2 |
MonoCollectList.java |  | 0% |  | 0% | 21 | 21 | 53 | 53 | 10 | 10 | 2 | 2 |
FluxElapsed.java |  | 0% |  | 0% | 27 | 27 | 52 | 52 | 18 | 18 | 2 | 2 |
FluxScan.java |  | 0% |  | 0% | 23 | 23 | 50 | 50 | 12 | 12 | 2 | 2 |
BaseSubscriber.java |  | 0% |  | 0% | 27 | 27 | 63 | 63 | 20 | 20 | 1 | 1 |
FluxDematerialize.java |  | 0% |  | 0% | 28 | 28 | 52 | 52 | 12 | 12 | 2 | 2 |
Signal.java |  | 0% |  | 0% | 35 | 35 | 28 | 28 | 17 | 17 | 1 | 1 |
MonoMaterialize.java |  | 0% |  | 0% | 26 | 26 | 52 | 52 | 13 | 13 | 2 | 2 |
FluxConcatIterable.java |  | 0% |  | 0% | 19 | 19 | 57 | 57 | 8 | 8 | 2 | 2 |
FluxDoFinally.java |  | 0% |  | 0% | 26 | 26 | 48 | 48 | 17 | 17 | 3 | 3 |
OperatorDisposables.java |  | 0% |  | 0% | 26 | 26 | 50 | 50 | 9 | 9 | 1 | 1 |
FluxMerge.java |  | 0% |  | 0% | 10 | 10 | 30 | 30 | 4 | 4 | 1 | 1 |
FluxTakeWhile.java |  | 0% |  | 0% | 21 | 21 | 48 | 48 | 12 | 12 | 2 | 2 |
FluxDetach.java |  | 0% |  | 0% | 28 | 28 | 45 | 45 | 13 | 13 | 2 | 2 |
FluxTakeUntil.java |  | 0% |  | 0% | 21 | 21 | 47 | 47 | 12 | 12 | 2 | 2 |
FluxProcessor.java |  | 0% |  | 0% | 33 | 33 | 36 | 36 | 20 | 20 | 1 | 1 |
MonoCallable.java |  | 0% |  | 0% | 25 | 25 | 52 | 52 | 16 | 16 | 2 | 2 |
FluxSkipLast.java |  | 0% |  | 0% | 20 | 20 | 38 | 38 | 12 | 12 | 2 | 2 |
MonoCompletionStage.java |  | 0% |  | 0% | 25 | 25 | 51 | 51 | 14 | 14 | 2 | 2 |
FluxHide.java |  | 0% |  | 0% | 32 | 32 | 51 | 51 | 26 | 26 | 3 | 3 |
FluxCancelOn.java |  | 0% |  | 0% | 23 | 23 | 40 | 40 | 14 | 14 | 2 | 2 |
MonoSupplier.java |  | 0% |  | 0% | 25 | 25 | 48 | 48 | 16 | 16 | 2 | 2 |
FluxRetry.java |  | 0% |  | 0% | 19 | 19 | 41 | 41 | 9 | 9 | 2 | 2 |
ParallelFluxName.java |  | 0% |  | 0% | 16 | 16 | 34 | 34 | 7 | 7 | 1 | 1 |
MonoProcessor.java |  | 0% |  | 0% | 31 | 31 | 31 | 31 | 20 | 20 | 1 | 1 |
FluxRepeat.java |  | 0% |  | 0% | 19 | 19 | 41 | 41 | 9 | 9 | 2 | 2 |
ParallelPeek.java |  | 0% |  | 0% | 19 | 19 | 36 | 36 | 13 | 13 | 1 | 1 |
MonoSingleCallable.java |  | 0% |  | 0% | 18 | 18 | 40 | 40 | 7 | 7 | 1 | 1 |
ParallelRunOn.java |  | 0% |  | 0% | 12 | 12 | 26 | 26 | 5 | 5 | 1 | 1 |
SignalType.java |  | 0% |  | 0% | 11 | 11 | 22 | 22 | 2 | 2 | 1 | 1 |
MonoNext.java |  | 0% |  | 0% | 22 | 22 | 42 | 42 | 13 | 13 | 2 | 2 |
FluxSkip.java |  | 0% |  | 0% | 18 | 18 | 37 | 37 | 12 | 12 | 2 | 2 |
FluxRepeatPredicate.java |  | 0% |  | 0% | 17 | 17 | 40 | 40 | 9 | 9 | 2 | 2 |
SinkManySerialized.java |  | 0% |  | 0% | 17 | 17 | 31 | 31 | 11 | 11 | 1 | 1 |
InternalManySink.java |  | 0% |  | 0% | 19 | 19 | 39 | 39 | 3 | 3 | 1 | 1 |
ContextTrackingFunctionWrapper.java |  | 0% | | 0% | 9 | 9 | 24 | 24 | 7 | 7 | 2 | 2 |
MonoAny.java |  | 0% |  | 0% | 15 | 15 | 38 | 38 | 9 | 9 | 2 | 2 |
MonoAll.java |  | 0% |  | 0% | 15 | 15 | 38 | 38 | 9 | 9 | 2 | 2 |
DelegateProcessor.java |  | 0% |  | 0% | 18 | 18 | 32 | 32 | 13 | 13 | 1 | 1 |
ParallelFluxOnAssembly.java |  | 0% |  | 0% | 15 | 15 | 27 | 27 | 7 | 7 | 1 | 1 |
ParallelLiftFuseable.java |  | 0% |  | 0% | 14 | 14 | 33 | 33 | 6 | 6 | 1 | 1 |
ParallelConcatMap.java |  | 0% |  | 0% | 12 | 12 | 22 | 22 | 5 | 5 | 1 | 1 |
FluxOnErrorResume.java |  | 0% |  | 0% | 13 | 13 | 32 | 32 | 8 | 8 | 2 | 2 |
ParallelFlatMap.java |  | 0% |  | 0% | 11 | 11 | 24 | 24 | 5 | 5 | 1 | 1 |
ParallelLift.java |  | 0% |  | 0% | 12 | 12 | 27 | 27 | 6 | 6 | 1 | 1 |
ConnectableFlux.java |  | 0% | | 0% | 15 | 15 | 19 | 19 | 13 | 13 | 1 | 1 |
GroupedLiftFuseable.java |  | 0% |  | 0% | 13 | 13 | 25 | 25 | 6 | 6 | 1 | 1 |
ParallelLog.java |  | 0% |  | 0% | 11 | 11 | 21 | 21 | 5 | 5 | 1 | 1 |
FluxErrorOnRequest.java |  | 0% |  | 0% | 17 | 17 | 25 | 25 | 9 | 9 | 2 | 2 |
MonoToCompletableFuture.java |  | 0% |  | 0% | 14 | 14 | 28 | 28 | 7 | 7 | 1 | 1 |
MonoFlattenIterable.java |  | 0% |  | 0% | 8 | 8 | 21 | 21 | 4 | 4 | 1 | 1 |
ConnectableLiftFuseable.java |  | 0% |  | 0% | 13 | 13 | 20 | 20 | 6 | 6 | 1 | 1 |
ParallelMap.java |  | 0% |  | 0% | 10 | 10 | 20 | 20 | 4 | 4 | 1 | 1 |
ParallelFilter.java |  | 0% |  | 0% | 10 | 10 | 20 | 20 | 4 | 4 | 1 | 1 |
MonoHasElement.java |  | 0% |  | 0% | 14 | 14 | 29 | 29 | 9 | 9 | 2 | 2 |
FluxAutoConnect.java |  | 0% |  | 0% | 12 | 12 | 19 | 19 | 5 | 5 | 1 | 1 |
FluxAutoConnectFuseable.java |  | 0% |  | 0% | 12 | 12 | 19 | 19 | 5 | 5 | 1 | 1 |
SinkEmptySerialized.java |  | 0% |  | 0% | 12 | 12 | 22 | 22 | 8 | 8 | 1 | 1 |
MonoHasElements.java |  | 0% |  | 0% | 14 | 14 | 27 | 27 | 9 | 9 | 2 | 2 |
GroupedLift.java |  | 0% |  | 0% | 11 | 11 | 23 | 23 | 6 | 6 | 1 | 1 |
MonoCallableOnAssembly.java |  | 0% |  | 0% | 12 | 12 | 17 | 17 | 8 | 8 | 1 | 1 |
MonoIgnoreElements.java |  | 0% |  | 0% | 16 | 16 | 26 | 26 | 12 | 12 | 2 | 2 |
ConnectableLift.java |  | 0% |  | 0% | 11 | 11 | 18 | 18 | 6 | 6 | 1 | 1 |
MonoTap.java |  | 0% |  | 0% | 6 | 6 | 21 | 21 | 3 | 3 | 1 | 1 |
MonoTapFuseable.java |  | 0% |  | 0% | 6 | 6 | 21 | 21 | 3 | 3 | 1 | 1 |
FluxSwitchIfEmpty.java |  | 0% |  | 0% | 11 | 11 | 22 | 22 | 7 | 7 | 2 | 2 |
InternalEmptySink.java |  | 0% |  | 0% | 11 | 11 | 22 | 22 | 2 | 2 | 1 | 1 |
ParallelMergeOrdered.java |  | 0% |  | 0% | 8 | 8 | 16 | 16 | 4 | 4 | 1 | 1 |
FluxFromMonoOperator.java |  | 0% |  | 0% | 10 | 10 | 26 | 26 | 5 | 5 | 1 | 1 |
MonoRepeatWhen.java |  | 0% | | 0% | 5 | 5 | 20 | 20 | 3 | 3 | 1 | 1 |
MonoFromFluxOperator.java |  | 0% |  | 0% | 10 | 10 | 26 | 26 | 5 | 5 | 1 | 1 |
MonoRunnable.java |  | 0% | | 0% | 12 | 12 | 26 | 26 | 10 | 10 | 2 | 2 |
MonoSubscribeOnValue.java |  | 0% |  | 0% | 7 | 7 | 20 | 20 | 3 | 3 | 1 | 1 |
InternalConnectableFluxOperator.java |  | 0% |  | 0% | 10 | 10 | 26 | 26 | 5 | 5 | 1 | 1 |
ParallelFluxHide.java |  | 0% |  | 0% | 10 | 10 | 17 | 17 | 5 | 5 | 1 | 1 |
MonoLiftFuseable.java |  | 0% |  | 0% | 9 | 9 | 14 | 14 | 4 | 4 | 1 | 1 |
FluxLiftFuseable.java |  | 0% |  | 0% | 9 | 9 | 15 | 15 | 4 | 4 | 1 | 1 |
MonoFromPublisher.java |  | 0% |  | 0% | 10 | 10 | 25 | 25 | 6 | 6 | 1 | 1 |
MonoTimeout.java |  | 0% | | 0% | 7 | 7 | 16 | 16 | 6 | 6 | 1 | 1 |
InternalFluxOperator.java |  | 0% |  | 0% | 10 | 10 | 25 | 25 | 5 | 5 | 1 | 1 |
MonoExpand.java |  | 0% | | 0% | 5 | 5 | 17 | 17 | 3 | 3 | 1 | 1 |
FluxStream.java |  | 0% | | 0% | 4 | 4 | 19 | 19 | 3 | 3 | 1 | 1 |
MonoErrorSupplied.java |  | 0% | | 0% | 8 | 8 | 16 | 16 | 6 | 6 | 1 | 1 |
MonoOnAssembly.java |  | 0% |  | 0% | 9 | 9 | 12 | 12 | 5 | 5 | 1 | 1 |
MonoIgnorePublisher.java |  | 0% |  | 0% | 9 | 9 | 22 | 22 | 6 | 6 | 1 | 1 |
InternalOneSink.java |  | 0% |  | 0% | 9 | 9 | 20 | 20 | 1 | 1 | 1 | 1 |
ConnectableFluxOnAssembly.java |  | 0% |  | 0% | 11 | 11 | 13 | 13 | 6 | 6 | 1 | 1 |
MonoPeek.java |  | 0% | | 0% | 12 | 12 | 18 | 18 | 10 | 10 | 1 | 1 |
MonoPeekFuseable.java |  | 0% | | 0% | 12 | 12 | 18 | 18 | 10 | 10 | 1 | 1 |
MonoSubscribeOnCallable.java |  | 0% |  | 0% | 6 | 6 | 15 | 15 | 3 | 3 | 1 | 1 |
FluxSink.java |  | 0% | | n/a | 2 | 2 | 7 | 7 | 2 | 2 | 2 | 2 |
FluxSource.java |  | 0% |  | 0% | 10 | 10 | 17 | 17 | 6 | 6 | 1 | 1 |
FluxSourceFuseable.java |  | 0% |  | 0% | 10 | 10 | 17 | 17 | 6 | 6 | 1 | 1 |
MonoCount.java |  | 0% | | 0% | 11 | 11 | 17 | 17 | 9 | 9 | 2 | 2 |
FluxLift.java |  | 0% |  | 0% | 7 | 7 | 13 | 13 | 4 | 4 | 1 | 1 |
MonoLift.java |  | 0% |  | 0% | 7 | 7 | 13 | 13 | 4 | 4 | 1 | 1 |
FluxDistinctFuseable.java |  | 0% | | 0% | 4 | 4 | 10 | 10 | 3 | 3 | 1 | 1 |
ParallelArraySource.java |  | 0% |  | 0% | 9 | 9 | 14 | 14 | 4 | 4 | 1 | 1 |
FluxSourceMono.java |  | 0% | | 0% | 6 | 6 | 8 | 8 | 4 | 4 | 1 | 1 |
MonoSourceFuseable.java |  | 0% |  | 0% | 9 | 9 | 18 | 18 | 6 | 6 | 1 | 1 |
FluxSourceMonoFuseable.java |  | 0% | | 0% | 6 | 6 | 8 | 8 | 4 | 4 | 1 | 1 |
MonoSource.java |  | 0% |  | 0% | 9 | 9 | 18 | 18 | 6 | 6 | 1 | 1 |
InternalMonoOperator.java |  | 0% |  | 0% | 7 | 7 | 22 | 22 | 4 | 4 | 1 | 1 |
FluxCallableOnAssembly.java |  | 0% |  | 0% | 9 | 9 | 10 | 10 | 6 | 6 | 1 | 1 |
MonoRepeat.java |  | 0% |  | 0% | 6 | 6 | 12 | 12 | 3 | 3 | 1 | 1 |
MonoRetry.java |  | 0% |  | 0% | 6 | 6 | 12 | 12 | 3 | 3 | 1 | 1 |
FluxErrorSupplied.java |  | 0% | | 0% | 6 | 6 | 12 | 12 | 4 | 4 | 1 | 1 |
FluxDeferContextual.java |  | 0% | | 0% | 4 | 4 | 13 | 13 | 3 | 3 | 1 | 1 |
MonoError.java |  | 0% | | 0% | 8 | 8 | 12 | 12 | 6 | 6 | 1 | 1 |
MonoMap.java | | 0% | | 0% | 5 | 5 | 9 | 9 | 3 | 3 | 1 | 1 |
MonoMapFuseable.java | | 0% | | 0% | 5 | 5 | 9 | 9 | 3 | 3 | 1 | 1 |
FluxTakeFuseable.java | | 0% | | 0% | 5 | 5 | 8 | 8 | 3 | 3 | 1 | 1 |
MonoDelaySubscription.java | | 0% | | 0% | 5 | 5 | 9 | 9 | 4 | 4 | 1 | 1 |
MonoDeferContextual.java | | 0% | | 0% | 4 | 4 | 13 | 13 | 3 | 3 | 1 | 1 |
MonoRepeatPredicate.java | | 0% | | 0% | 5 | 5 | 10 | 10 | 3 | 3 | 1 | 1 |
MonoNameFuseable.java | | 0% |  | 0% | 7 | 7 | 12 | 12 | 3 | 3 | 1 | 1 |
MonoFilter.java | | 0% | | 0% | 5 | 5 | 8 | 8 | 3 | 3 | 1 | 1 |
MonoFilterFuseable.java | | 0% | | 0% | 5 | 5 | 8 | 8 | 3 | 3 | 1 | 1 |
MonoJust.java | | 0% | | 0% | 8 | 8 | 11 | 11 | 6 | 6 | 1 | 1 |
FluxNameFuseable.java | | 0% |  | 0% | 7 | 7 | 12 | 12 | 3 | 3 | 1 | 1 |
FluxDefer.java | | 0% | | 0% | 4 | 4 | 12 | 12 | 3 | 3 | 1 | 1 |
MonoLog.java | | 0% | | 0% | 5 | 5 | 9 | 9 | 3 | 3 | 1 | 1 |
FluxLog.java | | 0% | | 0% | 5 | 5 | 9 | 9 | 3 | 3 | 1 | 1 |
MonoDefer.java | | 0% | | 0% | 4 | 4 | 12 | 12 | 3 | 3 | 1 | 1 |
ConnectableFluxHide.java | | 0% |  | 0% | 8 | 8 | 10 | 10 | 5 | 5 | 1 | 1 |
MonoTakeUntilOther.java | | 0% | | 0% | 4 | 4 | 9 | 9 | 3 | 3 | 1 | 1 |
MonoLogFuseable.java | | 0% | | 0% | 5 | 5 | 8 | 8 | 3 | 3 | 1 | 1 |
FluxLogFuseable.java | | 0% | | 0% | 5 | 5 | 8 | 8 | 3 | 3 | 1 | 1 |
BufferOverflowStrategy.java | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 | 1 | 1 |
SinkOneSerialized.java | | 0% | | 0% | 4 | 4 | 9 | 9 | 2 | 2 | 1 | 1 |
MonoContextWrite.java | | 0% | | 0% | 4 | 4 | 7 | 7 | 3 | 3 | 1 | 1 |
FluxError.java | | 0% | | 0% | 6 | 6 | 10 | 10 | 4 | 4 | 1 | 1 |
FluxJust.java | | 0% | | 0% | 6 | 6 | 9 | 9 | 4 | 4 | 1 | 1 |
MonoSwitchIfEmpty.java | | 0% | | 0% | 4 | 4 | 8 | 8 | 3 | 3 | 1 | 1 |
MonoOnErrorReturn.java | | 0% | | 0% | 4 | 4 | 7 | 7 | 3 | 3 | 1 | 1 |
MonoElapsed.java | | 0% | | 0% | 5 | 5 | 7 | 7 | 3 | 3 | 1 | 1 |
MonoTimed.java | | 0% | | 0% | 5 | 5 | 7 | 7 | 3 | 3 | 1 | 1 |
MonoCancelOn.java | | 0% | | 0% | 5 | 5 | 7 | 7 | 3 | 3 | 1 | 1 |
MonoRetryWhen.java | | 0% | | 0% | 4 | 4 | 7 | 7 | 3 | 3 | 1 | 1 |
MonoEmpty.java | | 0% | | 0% | 9 | 9 | 11 | 11 | 8 | 8 | 1 | 1 |
SourceProducer.java | | 0% | | 0% | 4 | 4 | 4 | 4 | 2 | 2 | 1 | 1 |
FluxDoOnEachFuseable.java | | 0% | | 0% | 4 | 4 | 6 | 6 | 3 | 3 | 1 | 1 |
MonoHandle.java | | 0% | | 0% | 4 | 4 | 6 | 6 | 3 | 3 | 1 | 1 |
MonoDoOnEach.java | | 0% | | 0% | 4 | 4 | 6 | 6 | 3 | 3 | 1 | 1 |
MonoHandleFuseable.java | | 0% | | 0% | 4 | 4 | 6 | 6 | 3 | 3 | 1 | 1 |
FluxCallable.java | | 0% | | 0% | 5 | 5 | 8 | 8 | 4 | 4 | 1 | 1 |
MonoDoOnEachFuseable.java | | 0% | | 0% | 4 | 4 | 6 | 6 | 3 | 3 | 1 | 1 |
MonoOnErrorResume.java | | 0% | | 0% | 4 | 4 | 6 | 6 | 3 | 3 | 1 | 1 |
MonoDefaultIfEmpty.java | | 0% | | 0% | 4 | 4 | 6 | 6 | 3 | 3 | 1 | 1 |
BlockingFirstSubscriber.java | | 0% | | 0% | 6 | 6 | 11 | 11 | 4 | 4 | 1 | 1 |
MonoCurrentContext.java | | 0% | | 0% | 5 | 5 | 7 | 7 | 4 | 4 | 1 | 1 |
FluxOperator.java | | 0% | | 0% | 4 | 4 | 6 | 6 | 2 | 2 | 1 | 1 |
BlockingMonoSubscriber.java | | 0% | | 0% | 6 | 6 | 10 | 10 | 4 | 4 | 1 | 1 |
FluxTakeLastOne.java | | 0% | | 0% | 5 | 5 | 6 | 6 | 4 | 4 | 1 | 1 |
FluxNever.java | | 0% | | 0% | 6 | 6 | 8 | 8 | 5 | 5 | 1 | 1 |
MonoOperator.java | | 0% | | 0% | 4 | 4 | 6 | 6 | 2 | 2 | 1 | 1 |
MonoNever.java | | 0% | | 0% | 6 | 6 | 8 | 8 | 5 | 5 | 1 | 1 |
MonoDoFirst.java | | 0% | | 0% | 4 | 4 | 7 | 7 | 3 | 3 | 1 | 1 |
FluxDoFirst.java | | 0% | | 0% | 4 | 4 | 7 | 7 | 3 | 3 | 1 | 1 |
MonoDoFirstFuseable.java | | 0% | | 0% | 4 | 4 | 7 | 7 | 3 | 3 | 1 | 1 |
FluxDoFirstFuseable.java | | 0% | | 0% | 4 | 4 | 7 | 7 | 3 | 3 | 1 | 1 |
MonoDoFinally.java | | 0% | | 0% | 4 | 4 | 6 | 6 | 3 | 3 | 1 | 1 |
MonoSingleMono.java | | 0% | | 0% | 4 | 4 | 5 | 5 | 3 | 3 | 1 | 1 |
MonoSourceFlux.java | | 0% | | 0% | 4 | 4 | 6 | 6 | 3 | 3 | 1 | 1 |
MonoDematerialize.java | | 0% | | 0% | 4 | 4 | 5 | 5 | 3 | 3 | 1 | 1 |
FluxEmpty.java | | 0% | | 0% | 6 | 6 | 7 | 7 | 5 | 5 | 1 | 1 |
MonoSourceFluxFuseable.java | | 0% | | 0% | 4 | 4 | 6 | 6 | 3 | 3 | 1 | 1 |
BlockingLastSubscriber.java | | 0% | | n/a | 4 | 4 | 8 | 8 | 4 | 4 | 1 | 1 |
MonoDetach.java | | 0% | | 0% | 4 | 4 | 5 | 5 | 3 | 3 | 1 | 1 |
MonoIgnoreElement.java | | 0% | | 0% | 4 | 4 | 5 | 5 | 3 | 3 | 1 | 1 |
MonoHide.java | | 0% | | 0% | 4 | 4 | 5 | 5 | 3 | 3 | 1 | 1 |
MonoBridges.java | | 0% | | n/a | 3 | 3 | 3 | 3 | 3 | 3 | 1 | 1 |
InnerProducer.java | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 | 1 | 1 |
SignalPeek.java | | 0% | | n/a | 2 | 2 | 2 | 2 | 2 | 2 | 1 | 1 |
InnerOperator.java | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 | 1 | 1 |
GroupedFlux.java | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 | 1 | 1 |
SynchronousSink.java | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 | 1 | 1 |
MonoSink.java | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 | 1 | 1 |