reactor.core.publisher

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethodsMissedClasses
Total119,811 of 119,8110%16,754 of 16,7540%14,95614,95633,10433,1046,5526,552715715
Flux4,7680%2480%59559587687647147111
Mono2,8770%1760%34134148048025325311
FluxWindowTimeout.InnerWindow1,4650%3040%194194371371424211
FluxWindowTimeout.WindowTimeoutWithBackpressureSubscriber1,3050%2480%151151342342272711
FluxFlatMap.FlatMapMain1,2780%2640%158158364364262611
Operators1,1010%1820%160160347347696911
FluxFlattenIterable.FlattenIterableSubscriber1,0950%1660%102102355355191911
ParallelFlux9410%420%101101171171808011
EmitterProcessor9370%1780%125125252252363611
SinkManyEmitterProcessor9340%1840%122122250250303011
FluxPublishMulticast.FluxPublishMulticaster8930%1540%9393263263161611
FluxPublishOn.PublishOnSubscriber8760%1420%9494268268232311
FluxPublishOn.PublishOnConditionalSubscriber8650%1420%9494266266232311
SignalLogger8310%1500%101101142142262611
FluxPublish.PublishSubscriber7880%1480%9393207207191911
NextProcessor7680%1410%102102211211282811
FluxWindowPredicate.WindowPredicateMain7400%1360%9494231231262611
UnicastProcessor7090%1200%104104221221444411
FluxBufferWhen.BufferWhenMainSubscriber7030%980%6464209209151511
FluxReplay.ReplaySubscriber7020%1180%8585181181262611
Hooks6940%380%6161208208424211
FluxJoin.JoinSubscription6670%700%4949196196141411
ParallelSource.ParallelSourceMain6630%1000%6464198198141411
FluxFilterWhen.FluxFilterWhenSubscriber6480%980%6767192192181811
FluxGroupJoin.GroupJoinSubscription6480%680%4848183183141411
FluxWindowTimeout.WindowTimeoutSubscriber6370%840%5656210210141411
FluxSwitchOnFirst6150%1160%8585130130272711
FluxSwitchOnFirst.AbstractSwitchOnFirstMain6090%1200%7373172172131311
SinkManyUnicast6070%1140%8787187187303011
FluxReplay.SizeAndTimeBoundReplayBuffer6000%1060%7070171171171711
FluxCombineLatest.CombineLatestCoordinator5950%880%6666181181222211
FluxMergeSequential.MergeSequentialMain5910%1100%7272189189171711
FluxGroupBy.GroupByMain5910%960%7070178178222211
FluxMergeComparing.MergeOrderedMainProducer5830%900%5656152152111111
FluxConcatMap.ConcatMapImmediate5720%940%6161156156141411
FluxHandleFuseable.HandleFuseableConditionalSubscriber5660%820%6262185185212111
FluxHandleFuseable.HandleFuseableSubscriber5620%840%6363183183212111
FluxOnBackpressureBuffer.BackpressureBufferSubscriber5500%1120%7575167167191911
FluxBufferPredicate.BufferPredicateSubscriber5400%920%6868151151222211
FluxSwitchMapNoPrefetch5360%920%6767133133212111
FluxConcatMap.ConcatMapDelayed5330%900%5959155155141411
FluxBufferTimeout.BufferTimeoutSubscriber5320%840%6060149149181811
FluxGroupBy.UnicastGroupedFlux5230%980%7171172172222211
FluxSwitchMap.SwitchMapMain5210%900%6464159159191911
FluxSwitchMapNoPrefetch.SwitchMapInner5190%840%5353148148111111
FluxWindow.WindowOverlapSubscriber5160%880%5959144144151511
FluxWindowPredicate.WindowFlux5150%940%6868162162212111
FluxOnBackpressureBufferTimeout.BackpressureBufferTimeoutSubscriber5100%840%5656160160141411
MonoZip.ZipCoordinator5050%900%6666122122212111
MonoPeekTerminal.MonoTerminalPeekSubscriber5050%860%6060144144171711
FluxPeekFuseable.PeekFuseableConditionalSubscriber5010%740%5353166166161611
FluxWindowBoundary.WindowBoundaryMain4890%680%5353147147191911
Operators.MultiSubscriptionSubscriber4830%1040%6969160160171711
FluxZip4810%480%3434129129101011
FluxZip.ZipCoordinator4760%760%4949145145111111
FluxOnBackpressureBufferStrategy.BackpressureBufferDropOldestSubscriber4730%890%5959155155141411
ParallelMergeSequential.MergeSequentialMain4720%960%6262141141141411
SerializedSubscriber4640%800%5353141141131311
FluxPeekFuseable.PeekFuseableSubscriber4570%680%4949152152151511
FluxGenerate.GenerateSubscription4530%740%5656145145191911
MonoCreate.DefaultMonoSink4440%960%6565128128171711
FluxWindowWhen.WindowWhenMainSubscriber4390%640%4646134134141411
MonoWhen.WhenCoordinator4340%820%6262102102212111
SinkManyReplayProcessor4250%500%5454109109292911
FluxSwitchMapNoPrefetch.SwitchMapMain4230%800%5353118118131311
SinkManyBestEffort4230%780%5454117117151511
DirectProcessor4210%580%5555117117242411
MonoIgnoreThen.ThenIgnoreMain4210%780%5858137137191911
FluxConcatMapNoPrefetch.FluxConcatMapNoPrefetchSubscriber4180%700%5151117117141411
MonoPublishMulticast.MonoPublishMulticaster4150%740%5151129129141411
ReplayProcessor4150%460%5454108108313111
FluxReplay.UnboundedReplayBuffer4120%620%4747136136161611
MonoUsing.MonoUsingSubscriber4070%780%5555112112161611
FluxReplay.SizeBoundReplayBuffer4070%720%5252134134161611
MonoDelayUntil.DelayUntilCoordinator4000%800%5656128128161611
FluxOnAssembly.OnAssemblyException3990%400%32329191121211
FluxExpand.ExpandDepthSubscription3950%680%4747130130131311
MonoSequenceEqual.EqualCoordinator3950%680%4545117117111111
ParallelMergeSort.MergeSortMain3950%660%4444120120111111
FluxSampleTimeout.SampleTimeoutMain3940%560%4444119119161611
FluxBufferBoundary.BufferBoundaryMain3740%520%4040110110141411
FluxMapSignal.FluxMapSignalSubscriber3690%460%39399696161611
FluxIterable.IterableSubscription3690%640%4646134134141411
FluxIterable.IterableSubscriptionConditional3640%640%4646132132141411
QueueDrainSubscriber3560%780%5656108108171711
DrainUtils3520%620%383897977711
FluxHandle.HandleConditionalSubscriber3510%480%4040110110161611
FluxSubscribeOnCallable.CallableSubscribeOnSubscription3500%780%5454106106151511
FluxHandle.HandleSubscriber3410%500%4141107107161611
MonoFilterWhen.MonoFilterWhenMain3400%600%49499191191911
FluxPeekFuseable.PeekConditionalSubscriber3370%480%3535114114111111
MonoDelay.MonoDelayRunnable3360%860%62628989191911
FluxBuffer.BufferOverlappingSubscriber3340%440%34348686121211
MonoCacheInvalidateIf.CoordinatorSubscriber3330%500%38388080131311
FluxTimeout.TimeoutMainSubscriber3310%440%36369797141411
ParallelThen.ThenMain3260%600%49497676191911
FluxDistinct.DistinctFuseableSubscriber3230%340%32329999151511
MonoCacheTime.CoordinatorSubscriber3230%440%38388888161611
FluxCreate.BaseSink3210%660%55558888222211
FluxOnBackpressureLatest.LatestSubscriber3190%680%46469494121211
FluxFilterFuseable.FilterFuseableSubscriber3130%440%3737100100151511
FluxFilterFuseable.FilterFuseableConditionalSubscriber3120%440%37379999151511
MonoCacheInvalidateWhen.CoordinatorSubscriber3110%420%35358181141411
FluxConcatArray.ConcatArrayDelayErrorSubscriber3100%540%38389595111111
MonoReduce.ReduceSubscriber3090%420%36369393151511
ParallelMergeReduce.MergeReduceMain3050%480%39398282151511
FluxWindow.WindowSkipSubscriber3000%480%37378484131311
FluxCreate.SerializedFluxSink3000%460%39398888161611
FluxMetrics2980%80%17176868131311
FluxTap.TapSubscriber2960%160%2222111111141411
FluxOnErrorReturn.ReturnSubscriber2940%600%41417676111111
Traces2910%500%343463639911
FluxPeek.PeekSubscriber2910%420%31319999101011
Operators.MonoInnerProducerBase2900%580%48488686191911
FluxOnAssembly.OnAssemblySubscriber2900%300%32327676171711
FluxTake.TakeFuseableSubscriber2820%480%39398484151511
FlatMapTracker2800%220%202072729911
Operators.MonoSubscriber2750%500%44448585191911
MonoDelayElement.DelayElementSubscriber2740%460%39397979161611
FluxBuffer.BufferSkipSubscriber2710%360%28287474101011
FluxArray.ArrayConditionalSubscription2680%440%34347575121211
FluxReplay2680%440%32327070101011
FluxArray.ArraySubscription2660%420%33337575121211
FluxMaterialize.MaterializeSubscriber2660%460%41416464181811
FluxMapFuseable.MapFuseableConditionalSubscriber2660%320%31317676151511
FluxConcatArray2650%260%23236161101011
SinkEmptyMulticast2610%380%31316868121211
MonoFlatMap.FlatMapMain2590%340%37378080202011
FluxCombineLatest2590%220%171770706611
FluxWithLatestFrom.WithLatestFromSubscriber2580%440%38388585161611
FluxDoOnEach.DoOnEachSubscriber2550%300%31317878161611
FluxDistinct.DistinctConditionalSubscriber2540%220%21217575101011
BlockingIterable.SubscriberIterator2500%380%31317474121211
FluxUsingWhen.UsingWhenSubscriber2490%300%27276363121211
FluxSampleFirst.SampleFirstMain2470%360%33337474151511
FluxWindow.WindowExactSubscriber2460%400%33337070131311
BlockingOptionalMonoSubscriber2450%400%32326666121211
FluxRefCountGrace2440%420%282867677711
MonoDelayUntil.DelayUntilTrigger2440%440%32327676101011
FluxTapFuseable.TapFuseableSubscriber2420%320%26267676101011
FluxMetrics.MetricsSubscriber2410%180%181861619911
FluxZip.ZipInner2390%420%31316161101011
FluxFlatMap2380%320%212167675511
FluxIndexFuseable.IndexFuseableConditionalSubscriber2380%240%27276969151511
SinkManyUnicastNoBackpressure2370%430%40406363141411
MonoCacheTime2350%240%23236666111111
StateLogger2330%120%121242426611
FluxTake.TakeConditionalSubscriber2320%360%29297070111111
StrictSubscriber2320%420%31316868101011
MonoFirstWithValue2320%180%151576766611
FluxRange.RangeSubscriptionConditional2300%420%33336666121211
FluxUsing.UsingFuseableSubscriber2290%360%34346363161611
MonoMetricsFuseable.MetricsFuseableSubscriber2290%340%27275454101011
FluxFirstWithValue2290%180%151574746611
FluxCreate.LatestAsyncSink2280%440%32327676101011
FluxFlatMap.FlatMapInner2270%420%31315757101011
FluxRange.RangeSubscription2260%400%32326464121211
FluxSubscribeOn.SubscribeOnSubscriber2240%360%31316262131311
FluxReplay.ReplayInner2240%300%39396565242411
FluxConcatArray.ConcatArraySubscriber2230%340%28287474111111
FluxMergeSequential.MergeSequentialInner2190%380%32325454131311
FluxSample.SampleMainSubscriber2180%400%36366868161611
FluxSubscribeOnValue.ScheduledScalar2180%480%36365656121211
LambdaMonoSubscriber2170%360%30307373121211
MonoTakeLastOne.TakeLastOneSubscriber2160%340%252566668811
MonoStreamCollector.StreamCollectorSubscriber2160%200%181871718811
BlockingSingleSubscriber2150%360%272755559911
FluxRetryWhen.RetryWhenMainSubscriber2120%200%27276060171711
FluxCreate.BufferAsyncSink2100%400%30307373101011
FluxFirstWithValue.RaceValuesCoordinator2100%320%242447478811
MonoSubscribeOn.SubscribeOnSubscriber2090%280%27275959131311
FluxMapFuseable.MapFuseableSubscriber2080%260%27276363141411
FluxZip.ZipSingleCoordinator2080%320%26265555101011
FluxSwitchOnFirst.SwitchOnFirstControlSubscriber2070%480%34346363101011
FluxFirstWithSignal.RaceCoordinator2070%340%252548488811
FluxMap.MapConditionalSubscriber2060%240%22225757101011
MonoFlatMapMany.FlatMapManyMain2060%260%25256565121211
FluxBuffer.BufferExactSubscriber2050%320%252558589911
FluxZip.ZipScalarCoordinator2040%320%27274949111111
ImmutableSignal2030%330%29294646111111
FluxMetricsFuseable.MetricsFuseableSubscriber2020%260%212146468811
FluxDelaySequence.DelaySubscriber2010%280%26264848121211
MonoZip2000%160%141447476611
FluxSwitchMap.SwitchMapInner1980%320%28285959121211
FluxUsing.UsingConditionalSubscriber1970%300%32325757171711
FluxDistinctUntilChanged.DistinctUntilChangedSubscriber1950%200%20206161101011
FluxIndexFuseable.IndexFuseableSubscriber1940%220%25255858141411
FluxDistinct.DistinctSubscriber1940%200%20205959101011
FluxDistinctUntilChanged.DistinctUntilChangedConditionalSubscriber1930%200%20205959101011
FluxUsing.UsingSubscriber1920%300%31315555161611
FluxSkipUntil.SkipUntilSubscriber1920%240%22226464101011
FluxSkipWhile.SkipWhileSubscriber1920%240%22226464101011
MonoPublishOn.PublishOnSubscriber1910%300%27275757121211
LambdaSubscriber1890%320%27275959111111
FluxFilter.FilterConditionalSubscriber1890%240%22226161101011
FluxFilter.FilterSubscriber1890%240%22226161101011
MonoCacheInvalidateWhen1870%280%222251518811
MonoFirstWithSignal1840%160%131363635511
FluxTakeUntilOther.TakeUntilMainSubscriber1830%360%32325858141411
FluxName1830%240%171742425511
MonoName1830%240%171742425511
FluxRefCount1820%300%212148486611
ParallelReduceSeed.ParallelReduceSeedSubscriber1820%280%212157577711
SinkOneMulticast1820%300%222241417711
FluxDefaultIfEmpty.DefaultIfEmptySubscriber1810%400%292952529911
FluxFirstWithSignal1810%160%131361615511
Operators.DeferredSubscription1810%360%262654548811
FluxZipIterable.ZipSubscriber1790%160%171756569911
FluxTake.TakeSubscriber1790%280%24245555101011
MonoCollect.CollectSubscriber1780%160%161660608811
MonoZip.ZipInner1770%360%272752529911
SinksSpecs.DefaultSinksSpecs1740%60%27274343242411
MonoDelayUntil1740%160%21213838131311
FluxMergeComparing1730%180%141431315511
MonoReduceSeed.ReduceSeedSubscriber1720%180%161652527711
FluxOnBackpressureDrop.DropSubscriber1720%240%22225353101011
BaseSubscriber1700%140%27276363202011
FluxIndex.IndexConditionalSubscriber1690%160%18185050101011
Operators.ScalarSubscription1670%300%28283939131311
Operators.LiftFunction1670%240%181834346611
MonoMetrics.MetricsSubscriber1660%120%151545459911
ParallelCollect.ParallelCollectSubscriber1660%220%181851517711
MonoSingle.SingleSubscriber1650%260%222253539911
Signal1640%360%35352828171711
ParallelMergeReduce.MergeReduceInner1610%280%232343439911
FluxMergeComparing.MergeOrderedInnerSubscriber1600%260%23234343101011
FluxExpand.ExpandBreathSubscriber1600%180%181852529911
FluxLimitRequest.FluxLimitRequestSubscriber1600%240%22225151101011
FluxIterable1590%220%181848487711
OperatorDisposables1580%340%262650509911
FluxSkipUntilOther.SkipUntilMainSubscriber1570%220%23234747121211
FluxRefCount.RefCountInner1570%220%26264242151511
Traces.StackWalkerCallSiteSupplierFactory1560%180%161641417711
MonoCollectList.MonoCollectListSubscriber1550%200%171748487711
FluxPublish1540%280%202044446611
MonoUsingWhen.ResourceSubscriber1530%220%191942428811
FluxUsingWhen.ResourceSubscriber1530%220%191942428811
ParallelGroup.ParallelInnerGroup1530%240%24244646121211
FluxMerge1530%120%101030304411
ReplayProcessor.ReplayInner1510%140%30304747232311
SinkManyReplayProcessor.ReplayInner1510%140%30304747232311
ParallelMergeSequential.MergeSequentialInner1500%240%23233838111111
FluxDematerialize.DematerializeSubscriber1490%300%242447479911
FluxProcessor1490%260%33333636202011
FluxRepeatWhen.RepeatWhenMainSubscriber1490%140%20204545131311
Operators.BaseFluxToMonoOperator1480%280%27275151131311
MonoMaterialize.MaterializeSubscriber1450%240%22224747101011
MonoWhen1450%140%121239395511
MonoCacheInvalidateIf1450%220%151545454411
FluxMap.MapSubscriber1440%180%181843439911
FluxContextWrite.ContextWriteSubscriber1440%240%28284545161611
FluxZip.ZipSingleSubscriber1440%240%212138389911
FluxScan.ScanSubscriber1440%200%191944449911
FluxElapsed.ElapsedSubscriber1430%140%22224545151511
ParallelFluxName1390%180%161634347711
FluxWindow1370%120%101029294411
FluxUsingWhen1370%80%9932325511
MonoSequenceEqual.EqualSubscriber1360%220%191935358811
MonoProcessor1360%220%31313131202011
FluxFirstWithValue.FirstValuesEmittingSubscriber1360%160%161633338811
ParallelPeek1340%120%19193636131311
MonoFilterWhen.FilterWhenInner1340%260%212139398811
FluxScanSeed.ScanSeedSubscriber1340%140%161646469911
MonoElementAt.ElementAtSubscriber1320%120%121237376611
FluxOnAssembly.ObservedAtInformationNode1320%180%151523236611
FluxDetach.DetachSubscriber1320%280%24244040101011
FluxFilterWhen.FilterWhenInner1320%280%232335359911
MonoSingleCallable1310%220%181840407711
ParallelRunOn1300%140%121226265511
FluxRefCountGrace.RefCountInner1300%120%21213939151511
FluxTimed.TimedSubscriber1300%140%161639399911
SinkManyBestEffort.DirectInner1290%220%22224040111111
SignalType1290%100%111122222211
FluxTimed.ImmutableTimed1290%140%151520208811
FluxIndex.IndexSubscriber1280%140%161640409911
FluxSwitchOnFirst.SwitchOnFirstConditionalMain1280%100%101035355511
FluxBufferWhen.BufferWhenCloseSubscriber1280%200%20203434101011
SinkManySerialized1270%120%17173131111111
InternalManySink1260%250%191939393311
FluxTakeWhile.TakeWhileSubscriber1240%160%171742429911
FluxTakeUntil.TakeUntilPredicateSubscriber1230%160%171741419911
MonoUsingWhen1210%60%8829295511
FluxCombineLatest.CombineLatestInner1210%160%18183232101011
FluxScanSeed.ScanSeedCoordinator1210%180%141436365511
MonoCompletionStage.MonoCompletionStageSubscription1210%200%21214444111111
MonoFlatMap.FlatMapInner1190%220%191934348811
FluxUsing1190%60%6630303311
DelegateProcessor1190%100%18183232131311
FluxTakeLast.TakeLastManySubscriber1180%160%19193333111111
FluxConcatIterable.ConcatIterableSubscriber1150%180%141442425511
ParallelFluxOnAssembly1150%160%151527277711
ParallelLiftFuseable1140%160%141433336611
MonoWhen.WhenInner1140%200%191936369911
FluxFlattenIterable1120%100%9930304411
FluxDoFinally.DoFinallySubscriber1120%140%18183636111111
MonoNext.NextSubscriber1110%160%18183737101011
ParallelCollect1110%120%121228286611
FluxDoOnEach.DoOnEachFuseableSubscriber1110%240%191932327711
ParallelReduceSeed1110%120%121228286611
FluxSample.SampleOther1100%180%161632327711
FluxSkipLast.SkipLastSubscriber1100%120%151530309911
FluxDelaySubscription.DelaySubscriptionOtherSubscriber1100%160%171736369911
FluxCancelOn.CancelSubscriber1090%140%18183333111111
FluxFirstWithSignal.FirstEmittingSubscriber1070%180%161630307711
MonoCallable.MonoCallableSubscription1070%160%18184040101011
FluxPublishOn1060%80%8819194411
FluxInterval.IntervalRunnable1050%160%151526267711
ParallelConcatMap1040%140%121222225511
FluxConcatMap1040%90%101018185511
BlockingIterable1040%80%101025256611
MonoSupplier.MonoSupplierSubscription1030%160%18183838101011
MonoUsing1030%40%5527273311
FluxSampleTimeout.SampleTimeoutOther1030%160%171727279911
ParallelDoOnEach1020%120%111125255511
ParallelFlatMap1020%120%111124245511
FluxBuffer1010%100%9918184411
FluxTimeout1000%60%8822225511
FluxSkipUntilOther.SkipUntilOtherSubscriber990%160%151531317711
FluxCreate.SerializeOnRequestSink980%60%16162525131311
FluxRange970%120%9924243311
FluxMergeSequential970%80%8819194411
SinksSpecs.UnsafeSpecImpl970%n/a24242626242411
Sinks.EmitResult970%80%9913135511
MonoAny.AnySubscriber960%100%111132326611
MonoAll.AllSubscriber960%100%111132326611
FluxPeek950%40%14143030121211
ParallelLift950%120%121227276611
FluxBufferWhen.BufferWhenOpenSubscriber950%140%17172626101011
FluxOnAssembly940%120%131324247711
FluxPublishMulticast.CancelFuseableMulticaster940%60%17173333141411
ConnectableFlux930%40%15151919131311
FluxExpand.ExpandDepthSubscriber930%160%18182828101011
GroupedLiftFuseable920%140%131325256611
ParallelLog910%120%111121215511
FluxGroupJoin910%0%4418183311
FluxSkip.SkipSubscriber900%80%131329299911
ConnectableLiftFuseable890%140%131320206611
MonoFlattenIterable890%80%8821214411
FluxRepeatPredicate.RepeatPredicateSubscriber890%120%121230306611
FluxRetry.RetrySubscriber890%140%131329296611
MonoToCompletableFuture890%140%141428287711
FluxTimeout.TimeoutTimeoutSubscriber890%120%16162828101011
FluxGroupJoin.LeftRightEndSubscriber880%120%16162424101011
FluxInterval880%80%7721213311
FluxCreate880%90%101021214411
FluxRepeat.RepeatSubscriber880%140%131329296611
ParallelFilter870%120%101020204411
ParallelMap870%120%101020204411
FluxPublishMulticast.PublishMulticastInner870%140%141425257711
Traces.SharedSecretsCallSiteSupplierFactory.TracingException860%140%101020203311
FluxWindowTimeout860%100%8819193311
FluxAutoConnectFuseable860%140%121219195511
FluxAutoConnect860%140%121219195511
ParallelSource860%120%111120205511
ParallelThen.ThenInner850%140%161622229911
FluxGroupJoin.LeftRightSubscriber850%120%16162424101011
ParallelMergeSort.MergeSortInner840%140%161623239911
FluxPublishMulticast840%60%7717174411
FluxJoin830%0%4417173311
SinkEmptySerialized830%80%121222228811
Traces.ExceptionCallSiteSupplierFactory.TracingException820%140%9919192211
FluxWindowWhen.WindowWhenCloseSubscriber820%100%131329298811
FluxPublishMulticast.CancelMulticaster810%60%17173232141411
GroupedLift810%100%111123236611
FluxPublish.PubSubInner810%160%151521217711
FluxSubscribeOnValue.ScheduledEmpty810%160%19192727111111
MonoCallableOnAssembly800%80%121217178811
FluxUsingWhen.RollbackInner800%100%121222227711
MonoDelay780%80%7718183311
ConnectableLift780%100%111118186611
FluxOnAssembly.AssemblySnapshot780%80%14142424101011
ParallelSource.ParallelSourceMain.ParallelSourceInner780%120%111123235511
FluxOnErrorResume.ResumeSubscriber770%80%9926265511
FluxTakeUntilOther.TakeUntilOtherSubscriber770%140%141424247711
FluxSwitchMap760%60%8815155511
ContextTrackingFunctionWrapper760%0%5516164411
FluxRetryWhen760%40%6622224411
FluxGenerate760%0%101022229911
FluxBufferTimeout760%80%7717173311
FluxWindowWhen750%60%7719194411
SinkEmptyMulticast.VoidInner750%120%151529299911
ParallelDoOnEach.DoOnEachSignalPeek750%60%15151313121211
FluxGroupBy740%40%6616164411
FluxWindowWhen.WindowWhenOpenSubscriber730%100%131326268811
MonoTapFuseable730%60%6621213311
MonoTap730%60%6621213311
FluxBufferWhen730%40%6616164411
InternalEmptySink720%150%111122222211
FluxUsingWhen.CommitInner720%80%111121217711
FluxConcatMap.ConcatMapInner720%80%101022226611
MonoSequenceEqual720%60%6615153311
MonoElementAt720%60%7715154411
Operators.new Fuseable.ConditionalSubscriber() {...}710%n/a7717177711
ParallelMergeOrdered710%80%8816164411
FluxPeekFuseable710%40%12122121101011
FluxDistinct710%40%5512123311
FluxWindowPredicate710%40%6616164411
ParallelMergeSequential700%80%8817174411
MonoCacheInvalidateWhen.TriggerSubscriber700%120%131317177711
MonoRepeatWhen690%40%5520203311
FluxFromMonoOperator690%100%101026265511
FluxSubscribeOn690%60%6617173311
FluxHide.SuppressFuseableSubscriber690%60%17172626141411
MonoIgnoreThen690%0%5517174411
FluxRepeatWhen690%40%5520203311
MonoFromFluxOperator680%100%101026265511
MonoHasElement.HasElementSubscriber680%80%101024246611
FluxTapFuseable670%40%5520203311
InternalConnectableFluxOperator670%100%101026265511
FluxSubscribeOnValue670%80%7720203311
FluxTap670%40%5520203311
FluxZip.PairwiseZipper670%0%4413133311
MonoSubscribeOnValue670%80%7720203311
FluxErrorOnRequest.ErrorSubscription660%140%131318186611
MonoLiftFuseable660%100%9914144411
ParallelFluxHide660%100%101017175511
FluxLiftFuseable660%100%9915154411
MonoFromPublisher660%80%101025256611
MonoTimeout650%0%7716166611
FluxRepeatWhen.RepeatWhenOtherSubscriber650%60%14142020111111
FluxRetryWhen.RetryWhenOtherSubscriber650%60%14142020111111
MonoPublishMulticast.PublishMulticastInner650%120%121220206611
InternalFluxOperator650%100%101025255511
MonoExpand640%40%5517173311
FluxExpand640%40%5517173311
FluxDoOnEach640%80%8813134411
FluxStream640%0%4419193311
FluxConcatMapNoPrefetch.FluxConcatMapNoPrefetchSubscriber.State640%n/a11771111
MonoErrorSupplied630%40%8816166611
MonoHasElements.HasElementsSubscriber630%80%101022226611
MonoOnAssembly620%80%9912125511
FluxSubscribeOnCallable610%60%6616163311
MonoIgnorePublisher610%60%9922226611
ConnectableFluxOnAssembly600%100%111113136611
MonoFlatMapMany.FlatMapManyInner600%80%111118187711
MonoIgnoreElements.IgnoreElementsSubscriber600%60%121221219911
InternalOneSink600%120%9920201111
MonoSubscribeOnCallable590%60%6615153311
FluxTakeLast.TakeLastZeroSubscriber590%60%121221219911
MonoPeek590%40%12121818101011
FluxBufferBoundary590%40%6613134411
MonoPeekFuseable590%40%12121818101011
MonoSubscribeOn580%60%6616163311
FluxSource570%80%101017176611
FluxSourceFuseable570%80%101017176611
FluxLimitRequest570%80%8813134411
MonoRunnable560%40%8821216611
FluxCreate.IgnoreSink550%80%7714143311
FluxDistinctFuseable550%0%4410103311
ParallelGroup550%80%7714143311
FluxWindowBoundary550%40%6614144411
FluxLift550%60%7713134411
FluxHide.HideSubscriber550%40%111120209911
MonoLift550%60%7713134411
FluxOnBackpressureBufferStrategy550%80%8812124411
FluxArray550%80%8815154411
MonoPublishMulticast540%40%5511113311
FluxSink.OverflowStrategy540%n/a11661111
ParallelArraySource540%100%9914144411
FluxPublish.PublishInner530%140%111115154411
FluxTake520%60%7711114411
FluxRetry510%60%6612123311
FluxBufferPredicate510%0%5511114411
MonoSourceFuseable500%60%9918186611
FluxSourceMonoFuseable500%40%66884411
ParallelMergeSort500%60%7714144411
InternalMonoOperator500%60%7722224411
FluxSourceMono500%40%66884411
FluxOnBackpressureBufferTimeout500%40%7713135511
MonoSource500%60%9918186611
FluxCallableOnAssembly490%60%9910106611
FluxZipIterable490%40%5512123311
OnNextFailureStrategy.ResumeDropStrategy480%100%8815153311
OnNextFailureStrategy.ResumeStrategy480%80%7714143311
FluxSampleFirst.SampleFirstOther480%60%101017177711
NextProcessor.NextInner480%100%101017175511
FluxConcatIterable470%40%5515153311
FluxTakeLast470%60%7711114411
FluxDistinctUntilChanged470%40%55993311
MonoRepeat460%60%6612123311
FluxBufferBoundary.BufferBoundaryOther460%60%101018187711
FluxWithLatestFrom460%0%4411113311
FluxWindowBoundary.WindowBoundaryOther460%60%101018187711
FluxRepeat460%60%6612123311
FluxDelaySubscription.DelaySubscriptionMainSubscriber460%40%9916167711
FluxScanSeed460%40%5511113311
ContextTrackingFunctionWrapper.new CorePublisher() {...}460%0%44993311
MonoDelayElement450%40%55993311
FluxUsingWhen.CancelInner450%60%101015157711
SinksSpecs.UnicastSpecImpl450%0%7714146611
FluxWithLatestFrom.WithLatestFromOtherSubscriber450%40%9918187711
FluxSampleTimeout450%0%5511114411
FluxConcatMapNoPrefetch440%40%6610104411
FluxMapSignal440%80%7710103311
MonoRetry440%60%6612123311
SinkManyUnicastNoBackpressure.State440%n/a11551111
MonoSingle440%40%6612124411
FluxBufferPredicate.ChangedPredicate430%40%5513133311
FluxErrorSupplied430%40%6612124411
FluxOnBackpressureBuffer430%40%6611114411
FluxSwitchIfEmpty.SwitchIfEmptySubscriber420%60%7714144411
FluxIndex.NullSafeIndexMapper420%40%5510103311
MonoUsingWhen.MonoUsingWhenSubscriber420%0%5513134411
FluxSample410%0%5511114411
MonoError410%40%8812126611
SinksSpecs.AbstractSerializedSink410%60%6611113311
FluxDelaySubscription410%0%6610105511
FluxDeferContextual410%0%4413133311
MonoCallable410%0%7712126611
FluxIndex400%40%55993311
FluxIndexFuseable400%40%55993311
MonoStreamCollector400%0%4410103311
ParallelMergeReduce.SlotPair400%60%7712124411
FluxSkip0%40%55883311
FluxHandle0%40%55993311
MonoDeferContextual0%0%4413133311
MonoMapFuseable0%40%55993311
FluxTimeout.TimeoutOtherSubscriber0%0%8815157711
FluxTakeFuseable0%40%55883311
FluxHandleFuseable0%40%55993311
FluxOnBackpressureDrop0%0%8812127711
FluxMap0%40%55993311
MonoReduceSeed0%0%44883311
MonoMap0%40%55993311
MonoDelaySubscription0%0%55994411
MonoCreate0%0%5514144411
FluxMapFuseable0%40%55993311
FluxRepeatPredicate0%40%5510103311
MonoCount.CountSubscriber0%0%7712126611
FluxRefCountGrace.RefConnection0%60%8811115511
MonoCollect0%0%44883311
MonoPeekTerminal0%40%5510103311
ParallelMergeReduce0%40%5511113311
MonoRepeatPredicate0%40%5510103311
Sinks.EmissionException0%n/a44994411
FluxDoFinally0%40%66994411
MonoJust0%40%8811116611
MonoFlatMap0%40%55883311
FluxDefer0%0%4412123311
FluxFilter0%40%55883311
FluxMetricsFuseable0%0%44883311
MonoNameFuseable0%80%7712123311
FluxNameFuseable0%80%7712123311
OnNextFailureStrategy0%n/a77887711
MonoFilterFuseable0%40%55883311
FluxSkipLast0%40%55883311
FluxFilterFuseable0%40%55883311
MonoFilter0%40%55883311
MonoMetricsFuseable0%0%44883311
FluxTakeUntilOther0%0%5510104411
MonoSupplier0%0%7710106611
FluxDelaySequence0%40%55993311
MonoMetrics0%0%44883311
FluxConcatMap.WeakScalarSubscription0%40%5512123311
MonoDefer0%0%4412123311
FluxCreate.NoOverflowBaseAsyncSink0%40%4411112211
FluxLog0%40%55993311
MonoLog0%40%55993311
FluxWindowTimeout.WindowTimeoutSubscriber.ConsumerIndexHolder0%40%4413132211
Operators.CorePublisherAdapter0%0%7715156611
Operators.ConditionalSubscriberAdapter0%n/a7714147711
FluxSkipUntilOther0%0%44993311
ConnectableFluxHide0%60%8810105511
MonoTakeUntilOther0%0%44993311
FluxReplay.SizeAndTimeBoundReplayBuffer.TimedNode0%n/a22662211
MonoLogFuseable0%40%55883311
FluxConcatMap.ErrorMode0%n/a11441111
MonoFlatMapMany0%40%55883311
BufferOverflowStrategy0%n/a11441111
FluxLogFuseable0%40%55883311
FluxBufferPredicate.Mode0%n/a11221111
Operators.EmptySubscription0%0%12121313111111
MonoTakeLastOne0%0%55994411
SinkOneSerialized0%40%44992211
SinkManyEmitterProcessor.EmitterDisposable0%100%8810103311
FluxSampleFirst0%0%55994411
EmitterProcessor.EmitterDisposable0%100%8810103311
FluxContextWrite0%0%44773311
FluxJust0%40%66994411
FluxError0%40%6610104411
MonoContextWrite0%0%44773311
OnNextFailureStrategy.LambdaOnNextErrorStrategy0%0%55884411
FluxCancelOn0%40%55773311
MonoCacheInvalidateWhen.CacheMonoSubscriber0%60%6610103311
FluxSwitchIfEmpty0%0%44883311
MonoCacheInvalidateIf.CacheMonoSubscriber0%60%6610103311
MonoSwitchIfEmpty0%0%44883311
FluxOnAssembly.CheckpointLightSnapshot0%0%55664411
ParallelThen0%40%55993311
MonoOnErrorReturn0%0%44773311
MonoCancelOn0%40%55773311
Flux.new Predicate() {...}0%40%44222211
MonoPublishOn0%40%55773311
SinkOneMulticast.NextInner0%40%6611114411
MonoTimed0%40%55773311
FluxOnErrorReturn0%0%44773311
FluxElapsed0%40%55773311
MonoElapsed0%40%55773311
FluxFilterWhen0%0%44773311
Flux.new BooleanSupplier() {...}0%40%44222211
FluxRefCount.RefCountMonitor0%n/a5511115511
MonoEmpty0%0%9911118811
SourceProducer0%40%44442211
MonoRetryWhen0%0%44773311
MonoDoOnEach0%0%44663311
MonoHandleFuseable0%0%44663311
MonoReduce0%0%44663311
MonoDoOnEachFuseable0%0%44663311
FluxScan0%0%44663311
FluxSkipWhile0%0%44663311
MonoOnErrorResume0%0%44663311
FluxTapFuseable.TapConditionalFuseableSubscriber0%0%3310102211
FluxCallable0%0%55884411
MonoHandle0%0%44663311
MonoAny0%0%44663311
MonoAll0%0%44663311
FluxSkipUntil0%0%44663311
FluxTakeWhile0%0%44663311
FluxOnErrorResume0%0%44663311
FluxDoOnEachFuseable0%0%44663311
FluxTakeUntil0%0%44663311
FluxTap.TapConditionalSubscriber0%0%3310102211
BlockingFirstSubscriber0%40%6611114411
FluxTimed0%0%55774411
MonoCompletionStage0%0%44773311
MonoDefaultIfEmpty0%0%44663311
FluxDefaultIfEmpty0%0%44663311
MonoCacheTime.CacheMonoSubscriber0%40%55993311
FluxOnAssembly.CheckpointHeavySnapshot0%0%33332211
FluxCreate.CreateMode0%n/a11221111
FluxErrorOnRequest0%0%44773311
MonoCurrentContext0%0%55774411
FluxOperator0%40%44662211
MonoFilterWhen0%0%44663311
FluxDoOnEach.DoOnEachFuseableConditionalSubscriber0%0%33772211
FluxCreate.SinkDisposable0%40%5510103311
FluxSwitchOnFirst.SwitchOnFirstConditionalControlSubscriber0%0%33772211
FluxDoOnEach.DoOnEachConditionalSubscriber0%0%33772211
BlockingMonoSubscriber0%40%6610104411
FluxTakeLastOne0%0%55664411
Sinks.OptimisticEmitFailureHandler0%40%44442211
MonoOperator0%40%44662211
FluxNever0%0%66885511
Operators.DrainSubscriber0%n/a77997711
MonoDoFirst0%0%44773311
FluxSwitchOnFirst.SwitchOnFirstMain0%n/a44774411
FluxDoFirstFuseable0%0%44773311
FluxReplay.SizeBoundReplayBuffer.Node0%n/a22552211
MonoNever0%0%66885511
FluxDoFirst0%0%44773311
MonoDoFinally0%0%44663311
MonoDoFirstFuseable0%0%44773311
FluxDelaySequence.DelaySubscriber.OnError0%n/a22662211
Operators.CancelledSubscription0%0%77886611
FluxOnBackpressureLatest0%0%55664411
MonoSingleMono0%0%44553311
MonoSourceFluxFuseable0%0%44663311
MonoDematerialize0%0%44553311
FluxCreate.ErrorAsyncSink0%n/a33553311
EmitterProcessor.EmitterInner0%n/a33883311
FluxDematerialize0%0%44553311
MonoSourceFlux0%0%44663311
FluxEmpty0%0%66775511
SinkManyEmitterProcessor.EmitterInner0%n/a33883311
MonoIgnoreElement0%0%44553311
MonoHasElement0%0%44553311
FluxHide0%0%44553311
BlockingLastSubscriber0%n/a44884411
MonoHide0%0%44553311
MonoCollectList0%0%44553311
MonoMaterialize0%0%44553311
FluxDetach0%0%44553311
MonoDetach0%0%44553311
MonoIgnoreElements0%0%44553311
MonoHasElements0%0%44553311
FluxMaterialize0%0%44553311
MonoCount0%0%44553311
MonoNext0%0%44553311
FluxTimeout.CancelledIndexedCancellable0%n/a33443311
Mono.new SignalListenerFactory() {...}0%n/a33333311
Flux.new SignalListenerFactory() {...}0%n/a33333311
Flux.new Function() {...}0%n/a22442211
OnNextFailureStrategy.new OnNextFailureStrategy() {...}0%n/a33663311
FluxUsingWhen.UsingWhenConditionalSubscriber0%n/a22442211
Mono.new SignalListenerFactory() {...}0%n/a33333311
Flux.new SignalListenerFactory() {...}0%n/a33333311
FluxCreate.DropAsyncSink0%n/a33443311
SerializedSubscriber.LinkedArrayNode0%n/a11551111
FluxDelaySequence.DelaySubscriber.OnComplete0%n/a22442211
FluxOnAssembly.OnAssemblyConditionalSubscriber0%n/a22442211
FluxOnAssembly.MethodReturnSnapshot0%n/a33553311
FluxCombineLatest.SourceAndArray0%n/a22552211
MonoCacheInvalidateIf.ValueState0%n/a33663311
SinksSpecs0%n/a22332211
Sinks0%n/a44444411
MonoRunnable.MonoRunnableEagerSubscription0%n/a44554411
FluxDoFinally.DoFinallyConditionalSubscriber0%n/a22332211
MonoBridges0%n/a33333311
Sinks.EmitFailureHandler0%n/a33223311
FluxWindowWhen.WindowOperation0%n/a11441111
QueueDrainSubscriberWip0%n/a11221111
QueueDrainSubscriberPad30%n/a22332211
InnerProducer0%0%22331111
Traces.SharedSecretsCallSiteSupplierFactory0%n/a22222211
Traces.ExceptionCallSiteSupplierFactory0%n/a22222211
MonoCacheInvalidateIf.new MonoCacheInvalidateIf.State() {...}0%n/a33333311
SignalPeek0%n/a22222211
InnerOperator0%n/a11111111
FluxSink0%n/a11111111
MonoSink0%n/a11111111
SynchronousSink0%n/a11111111
GroupedFlux0%n/a11111111
QueueDrainSubscriberPad00%n/a11111111
QueueDrainSubscriberPad40%n/a11111111
QueueDrainSubscriberPad20%n/a11111111