reactor.core.publisher

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethodsMissedClasses
Total115,929 of 115,9290%16,054 of 16,0540%14,38814,38831,88431,8846,3346,334708708
Flux4,8140%2540%60460488788747747711
Mono2,9280%1760%35135148748726326311
FluxWindowTimeout.InnerWindow1,4650%3040%194194371371424211
FluxWindowTimeout.WindowTimeoutWithBackpressureSubscriber1,3040%2480%151151342342272711
FluxFlatMap.FlatMapMain1,2810%2640%158158365365262611
FluxFlattenIterable.FlattenIterableSubscriber1,2180%1840%114114378378222211
Operators1,1380%1900%166166362362717111
ParallelFlux9410%420%101101171171808011
EmitterProcessor9370%1780%125125252252363611
FluxPublishMulticast.FluxPublishMulticaster8930%1540%9393263263161611
FluxPublishOn.PublishOnSubscriber8760%1420%9494268268232311
FluxPublishOn.PublishOnConditionalSubscriber8650%1420%9494266266232311
SignalLogger8310%1500%101101142142262611
FluxPublish.PublishSubscriber7960%1520%9595209209191911
FluxWindowPredicate.WindowPredicateMain7390%1360%9494231231262611
NextProcessor7200%1270%9292201201252511
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
FluxZip.ZipCoordinator6230%1020%6464185185131311
FluxSwitchOnFirst6150%1160%8585130130272711
FluxSwitchOnFirst.AbstractSwitchOnFirstMain6090%1200%7373172172131311
FluxMergeSequential.MergeSequentialMain6030%1120%7373192192171711
FluxMergeComparing.MergeOrderedMainProducer6010%1020%6262154154111111
FluxReplay.SizeAndTimeBoundReplayBuffer6000%1060%7070171171171711
FluxCombineLatest.CombineLatestCoordinator5950%880%6666181181222211
FluxGroupBy.GroupByMain5910%960%7070178178222211
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
FluxWindowPredicate.WindowFlux5150%940%6868162162212111
FluxWindow.WindowOverlapSubscriber5150%880%5959144144151511
FluxOnBackpressureBufferTimeout.BackpressureBufferTimeoutSubscriber5100%840%5656160160141411
MonoPeekTerminal.MonoTerminalPeekSubscriber5050%860%6060144144171711
FluxPeekFuseable.PeekFuseableConditionalSubscriber5010%740%5353166166161611
FluxZip4990%480%3434137137101011
FluxWindowBoundary.WindowBoundaryMain4880%680%5353147147191911
Operators.MultiSubscriptionSubscriber4830%1040%6969160160171711
FluxOnBackpressureBufferStrategy.BackpressureBufferDropOldestSubscriber4730%890%5959155155141411
ParallelMergeSequential.MergeSequentialMain4720%960%6262141141141411
SerializedSubscriber4640%800%5353141141131311
FluxPeekFuseable.PeekFuseableSubscriber4570%680%4949152152151511
FluxGenerate.GenerateSubscription4530%740%5656145145191911
MonoCreate.DefaultMonoSink4440%960%6565128128171711
FluxWindowWhen.WindowWhenMainSubscriber4380%640%4646134134141411
FluxSwitchMapNoPrefetch.SwitchMapMain4230%800%5353118118131311
SinkManyBestEffort4230%780%5454117117151511
DirectProcessor4210%580%5555117117242411
MonoIgnoreThen.ThenIgnoreMain4210%780%5858137137191911
FluxConcatMapNoPrefetch.FluxConcatMapNoPrefetchSubscriber4180%700%5151117117141411
FluxIterable.IterableSubscription4150%700%5252147147171711
MonoPublishMulticast.MonoPublishMulticaster4150%740%5151129129141411
ReplayProcessor4150%460%5454108108313111
FluxReplay.UnboundedReplayBuffer4120%620%4747136136161611
FluxIterable.IterableSubscriptionConditional4100%700%5252145145171711
FluxReplay.SizeBoundReplayBuffer4070%720%5252134134161611
MonoUsing.MonoUsingSubscriber4070%780%5555112112161611
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
QueueDrainSubscriber3560%780%5656108108171711
DrainUtils3520%620%383897977711
FluxHandle.HandleConditionalSubscriber3510%480%4040110110161611
FluxSubscribeOnCallable.CallableSubscribeOnSubscription3500%780%5454106106151511
FluxHandle.HandleSubscriber3410%500%4141107107161611
FluxPeekFuseable.PeekConditionalSubscriber3370%480%3535114114111111
MonoDelay.MonoDelayRunnable3360%860%62628989191911
FluxBuffer.BufferOverlappingSubscriber3340%440%34348686121211
MonoCacheInvalidateIf.CoordinatorSubscriber3330%500%38388080131311
FluxTimeout.TimeoutMainSubscriber3310%440%36369797141411
FluxDistinct.DistinctFuseableSubscriber3230%340%32329999151511
MonoCacheTime.CoordinatorSubscriber3230%440%38388888161611
FluxCreate.BaseSink3210%660%55558888222211
FluxOnBackpressureLatest.LatestSubscriber3190%680%46469494121211
FluxMetrics3150%80%17177070131311
FluxFilterFuseable.FilterFuseableSubscriber3130%440%3737100100151511
FluxFilterFuseable.FilterFuseableConditionalSubscriber3120%440%37379999151511
MonoCacheInvalidateWhen.CoordinatorSubscriber3110%420%35358181141411
FluxConcatArray.ConcatArrayDelayErrorSubscriber3100%540%38389595111111
SinkEmptyMulticast3040%500%38388181131311
FluxCreate.SerializedFluxSink3000%460%39398888161611
FluxWindow.WindowSkipSubscriber2990%480%37378484131311
FluxOnErrorReturn.ReturnSubscriber2940%600%41417676111111
FluxPeek.PeekSubscriber2910%420%31319999101011
Traces2910%500%343463639911
Operators.MonoInnerProducerBase2900%580%48488686191911
FluxOnAssembly.OnAssemblySubscriber2900%300%32327676171711
FluxTake.TakeFuseableSubscriber2820%480%39398484151511
FlatMapTracker2800%220%202072729911
FluxBuffer.BufferSkipSubscriber2710%360%28287474101011
FluxReplay2680%440%32327070101011
FluxArray.ArrayConditionalSubscription2680%440%34347575121211
FluxZip.ZipSingleCoordinator2680%440%33336969111111
FluxArray.ArraySubscription2660%420%33337575121211
FluxMaterialize.MaterializeSubscriber2660%460%41416464181811
FluxMapFuseable.MapFuseableConditionalSubscriber2660%320%31317676151511
MonoZip.ZipCoordinator2650%420%282870707711
FluxConcatArray2650%260%23236161101011
FluxCombineLatest2590%220%171770706611
FluxWithLatestFrom.WithLatestFromSubscriber2580%440%38388585161611
FluxDoOnEach.DoOnEachSubscriber2550%300%31317878161611
FluxDistinct.DistinctConditionalSubscriber2540%220%21217575101011
FluxZip.ZipInner2510%400%30306363101011
BlockingIterable.SubscriberIterator2500%380%31317474121211
FluxUsingWhen.UsingWhenSubscriber2490%300%27276363121211
FluxSampleFirst.SampleFirstMain2470%360%33337474151511
BlockingOptionalMonoSubscriber2450%400%32326666121211
FluxWindow.WindowExactSubscriber2450%400%33337070131311
MonoDelayUntil.DelayUntilTrigger2440%440%32327676101011
FluxRefCountGrace2440%420%282867677711
FluxMetrics.MetricsSubscriber2410%180%181861619911
FluxExtensionsKt2410%n/a21212323212111
FluxFlatMap2380%320%212167675511
FluxIndexFuseable.IndexFuseableConditionalSubscriber2380%240%27276969151511
UnicastManySinkNoBackpressure2370%430%40406363141411
MonoCacheTime2350%240%23236666111111
StateLogger2330%120%121242426611
StrictSubscriber2320%420%31316868101011
MonoFirstWithValue2320%180%151576766611
FluxTake.TakeConditionalSubscriber2320%360%29297070111111
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
MonoFilterWhen.MonoFilterWhenMain2250%360%29296767111111
FluxSubscribeOn.SubscribeOnSubscriber2240%360%31316262131311
FluxReplay.ReplayInner2240%300%39396565242411
FluxConcatArray.ConcatArraySubscriber2230%340%28287474111111
ParallelMergeReduce.MergeReduceMain2210%340%242458587711
FluxMergeSequential.MergeSequentialInner2190%380%32325454131311
FluxSubscribeOnValue.ScheduledScalar2180%480%36365656121211
FluxSample.SampleMainSubscriber2180%400%36366868161611
MonoZip2180%180%151551516611
Operators.MonoSubscriber2170%400%39396969191911
LambdaMonoSubscriber2170%360%30307373121211
BlockingSingleSubscriber2150%360%272755559911
MonoWhen.WhenCoordinator2140%360%262655558811
MonoCollect.CollectSubscriber2130%260%212169698811
FluxRetryWhen.RetryWhenMainSubscriber2120%200%27276060171711
FluxFirstWithValue.RaceValuesCoordinator2100%320%242447478811
FluxCreate.BufferAsyncSink2100%400%30307373101011
MonoSubscribeOn.SubscribeOnSubscriber2090%280%27275959131311
FluxMapFuseable.MapFuseableSubscriber2080%260%27276363141411
FluxTakeUntilOther.TakeUntilMainSubscriber2070%440%36366464141411
FluxSwitchOnFirst.SwitchOnFirstControlSubscriber2070%480%34346363101011
FluxFirstWithSignal.RaceCoordinator2070%340%252548488811
FluxMap.MapConditionalSubscriber2060%240%22225757101011
MonoFlatMapMany.FlatMapManyMain2060%260%25256565121211
FluxBuffer.BufferExactSubscriber2050%320%252558589911
ImmutableSignal2030%330%29294646111111
FluxMetricsFuseable.MetricsFuseableSubscriber2020%260%212146468811
FluxDelaySequence.DelaySubscriber2010%280%26264848121211
FluxSwitchMap.SwitchMapInner1980%320%28285959121211
FluxUsing.UsingConditionalSubscriber1970%300%32325757171711
MonoFlatMap.FlatMapMain1970%220%22226262111111
SinkOneMulticast1970%400%282850508811
FluxDistinctUntilChanged.DistinctUntilChangedSubscriber1950%200%20206161101011
FluxDistinct.DistinctSubscriber1940%200%20205959101011
FluxIndexFuseable.IndexFuseableSubscriber1940%220%25255858141411
FluxIterable1930%260%191969696611
FluxDistinctUntilChanged.DistinctUntilChangedConditionalSubscriber1930%200%20205959101011
FluxSkipUntil.SkipUntilSubscriber1920%240%22226464101011
FluxUsing.UsingSubscriber1920%300%31315555161611
FluxSkipWhile.SkipWhileSubscriber1920%240%22226464101011
MonoPublishOn.PublishOnSubscriber1910%300%27275757121211
LambdaSubscriber1890%320%27275959111111
FluxFilter.FilterConditionalSubscriber1890%240%22226161101011
FluxFilter.FilterSubscriber1890%240%22226161101011
MonoCacheInvalidateWhen1870%280%222251518811
MonoStreamCollector.StreamCollectorSubscriber1870%180%171758588811
MonoCollectList.MonoCollectListSubscriber1850%240%202059598811
MonoFirstWithSignal1840%160%131363635511
FluxRefCount1820%300%212148486611
FluxMergeComparing1820%180%141432325511
FluxFirstWithSignal1810%160%131361615511
Operators.DeferredSubscription1810%360%262654548811
FluxTake.TakeSubscriber1790%280%24245555101011
FluxZipIterable.ZipSubscriber1790%160%171756569911
FluxPublish1760%340%232350506611
FluxName1740%240%171740405511
MonoDelayUntil1740%160%21213838131311
MonoName1740%240%171740405511
MonoExtensionsKt1720%n/a11111111111111
FluxOnBackpressureDrop.DropSubscriber1720%240%22225353101011
MonoElementAt.ElementAtSubscriber1710%200%181848488811
SinksSpecs.DefaultSinksSpecs1710%60%27274646242411
BaseSubscriber1700%140%27276363202011
FluxIndex.IndexConditionalSubscriber1690%160%18185050101011
Signal1680%360%36362929181811
Operators.ScalarSubscription1670%300%28283939131311
Operators.LiftFunction1670%240%181834346611
MonoMetrics.MetricsSubscriber1660%120%151545459911
MonoSingle.SingleSubscriber1650%260%222253539911
FluxZip.ZipSingleSubscriber1650%340%262640409911
MonoZip.ZipInner1630%300%242447479911
FluxExpand.ExpandBreathSubscriber1600%180%181852529911
FluxMergeComparing.MergeOrderedInnerSubscriber1600%260%23234343101011
FluxLimitRequest.FluxLimitRequestSubscriber1600%240%22225151101011
ParallelMergeReduce.MergeReduceInner1590%280%232343439911
OperatorDisposables1580%340%262650509911
FluxSkipUntilOther.SkipUntilMainSubscriber1570%220%23234747121211
FluxRefCount.RefCountInner1570%220%26264242151511
MonoReduce.ReduceSubscriber1560%180%161650507711
Traces.StackWalkerCallSiteSupplierFactory1560%180%161641417711
MonoUsingWhen.ResourceSubscriber1530%220%191942428811
FluxUsingWhen.ResourceSubscriber1530%220%191942428811
ParallelGroup.ParallelInnerGroup1530%240%24244646121211
FluxMerge1530%120%101030304411
ReplayProcessor.ReplayInner1510%140%30304747232311
ParallelMergeSequential.MergeSequentialInner1500%240%23233838111111
FluxRepeatWhen.RepeatWhenMainSubscriber1490%140%20204545131311
FluxDematerialize.DematerializeSubscriber1490%300%242447479911
FluxProcessor1490%260%33333636202011
MonoWhen1470%140%121240405511
MonoMaterialize.MaterializeSubscriber1450%240%22224747101011
MonoCacheInvalidateIf1450%220%151545454411
FluxMap.MapSubscriber1440%180%181843439911
MonoDelayElement.DelayElementSubscriber1440%200%181843438811
FluxScan.ScanSubscriber1440%200%191944449911
FluxContextWrite.ContextWriteSubscriber1440%240%28284545161611
FluxElapsed.ElapsedSubscriber1430%140%22224545151511
MonoReduceSeed.ReduceSeedSubscriber1380%160%161643438811
FluxWindow1370%120%101029294411
FluxUsingWhen1370%80%9932325511
MonoProcessor1360%220%31313131202011
MonoSequenceEqual.EqualSubscriber1360%220%191935358811
FluxFirstWithValue.FirstValuesEmittingSubscriber1360%160%161633338811
ParallelFluxName1350%180%161633337711
ParallelPeek1340%120%19193636131311
FluxScanSeed.ScanSeedSubscriber1340%140%161646469911
MonoFilterWhen.FilterWhenInner1330%280%232335359911
FluxOnAssembly.ObservedAtInformationNode1320%180%151523236611
FluxDetach.DetachSubscriber1320%280%24244040101011
FluxFilterWhen.FilterWhenInner1320%280%232335359911
MonoSingleCallable1310%220%181840407711
ParallelRunOn1300%140%121226265511
FluxTimed.TimedSubscriber1300%140%161639399911
FluxRefCountGrace.RefCountInner1300%120%21213939151511
SignalType1290%100%111122222211
FluxTimed.ImmutableTimed1290%140%151520208811
SinkManyBestEffort.DirectInner1290%220%22224040111111
FluxBufferWhen.BufferWhenCloseSubscriber1280%200%20203434101011
FluxIndex.IndexSubscriber1280%140%161640409911
FluxSwitchOnFirst.SwitchOnFirstConditionalMain1280%100%101035355511
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
MonoAll.AllSubscriber1190%160%151539397711
FluxUsing1190%60%6630303311
DelegateProcessor1190%100%18183232131311
MonoAny.AnySubscriber1190%160%151539397711
ParallelThen.ThenMain1180%180%151526266611
FluxTakeLast.TakeLastManySubscriber1180%160%19193333111111
FluxConcatIterable.ConcatIterableSubscriber1150%180%141442425511
ParallelFluxOnAssembly1150%160%151527277711
ParallelLiftFuseable1140%160%141433336611
MonoFlatMap.FlatMapInner1130%200%191934349911
FluxDoFinally.DoFinallySubscriber1120%140%18183636111111
ParallelReduceSeed.ParallelReduceSeedSubscriber1120%100%121238387711
FluxFlattenIterable1120%100%9930304411
MonoNext.NextSubscriber1110%160%18183737101011
FluxDoOnEach.DoOnEachFuseableSubscriber1110%240%191932327711
ParallelReduceSeed1110%120%121228286611
ParallelCollect1110%120%121228286611
FluxSample.SampleOther1100%180%161632327711
FluxSkipLast.SkipLastSubscriber1100%120%151530309911
FluxDelaySubscription.DelaySubscriptionOtherSubscriber1100%160%171736369911
FluxCancelOn.CancelSubscriber1090%140%18183333111111
FluxFirstWithSignal.FirstEmittingSubscriber1070%180%161630307711
FluxPublishOn1060%80%8819194411
ParallelCollect.ParallelCollectSubscriber1050%100%121236367711
FluxInterval.IntervalRunnable1050%160%151526267711
ParallelConcatMap1040%140%121222225511
FluxConcatMap1040%90%101018185511
MonoCompletionStage1040%180%131331314411
BlockingIterable1040%80%101025256611
MonoUsing1030%40%5527273311
FluxSampleTimeout.SampleTimeoutOther1030%160%171727279911
ParallelFlatMap1020%120%111124245511
ParallelDoOnEach1020%120%111125255511
FluxBuffer1010%100%9918184411
FluxTimeout1000%60%8822225511
FluxSkipUntilOther.SkipUntilOtherSubscriber990%160%151531317711
FluxCreate.SerializeOnRequestSink980%60%16162525131311
FluxMergeSequential970%80%8819194411
SinksSpecs.UnsafeSpecImpl970%n/a24242626242411
Sinks.EmitResult970%80%9913135511
FluxRange970%120%9924243311
MonoTakeLastOne.TakeLastOneSubscriber950%120%121230306611
FluxBufferWhen.BufferWhenOpenSubscriber950%140%17172626101011
FluxPeek950%40%14143030121211
ParallelLift950%120%121227276611
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
FluxRepeatPredicate.RepeatPredicateSubscriber890%120%121230306611
FluxRetry.RetrySubscriber890%140%131329296611
FluxTimeout.TimeoutTimeoutSubscriber890%120%16162828101011
ConnectableLiftFuseable890%140%131320206611
MonoFlattenIterable890%80%8821214411
MonoToCompletableFuture890%140%141428287711
FluxGroupJoin.LeftRightEndSubscriber880%120%16162424101011
FluxCreate880%90%101021214411
FluxTakeUntilOther.TakeUntilOtherSubscriber880%160%151528287711
FluxInterval880%80%7721213311
FluxRepeat.RepeatSubscriber880%140%131329296611
ParallelFilter870%120%101020204411
ParallelMap870%120%101020204411
FluxPublishMulticast.PublishMulticastInner870%140%141425257711
FluxAutoConnectFuseable860%140%121219195511
FluxAutoConnect860%140%121219195511
ParallelSource860%120%111120205511
Traces.SharedSecretsCallSiteSupplierFactory.TracingException860%140%101020203311
FluxWindowTimeout860%100%8819193311
FluxGroupJoin.LeftRightSubscriber850%120%16162424101011
ParallelMergeSort.MergeSortInner840%140%161623239911
FluxPublishMulticast840%60%7717174411
SinkEmptySerialized830%80%121222228811
MonoWhen.WhenInner830%140%161629299911
FluxJoin830%0%4417173311
ParallelThen.ThenInner820%140%161622229911
FluxWindowWhen.WindowWhenCloseSubscriber820%100%131329298811
Traces.ExceptionCallSiteSupplierFactory.TracingException820%140%9919192211
GroupedLift810%100%111123236611
FluxSubscribeOnValue.ScheduledEmpty810%160%19192727111111
FluxPublishMulticast.CancelMulticaster810%60%17173232141411
FluxPublish.PubSubInner810%160%151521217711
MonoCallableOnAssembly800%80%121217178811
FluxUsingWhen.RollbackInner800%100%121222227711
ConnectableLift780%100%111118186611
FluxOnAssembly.AssemblySnapshot780%80%14142424101011
MonoDelay780%80%7718183311
ParallelSource.ParallelSourceMain.ParallelSourceInner780%120%111123235511
FluxOnErrorResume.ResumeSubscriber770%80%9926265511
FluxSwitchMap760%60%8815155511
ContextTrackingFunctionWrapper760%0%5516164411
FluxRetryWhen760%40%6622224411
FluxBufferTimeout760%80%7717173311
FluxGenerate760%0%101022229911
FluxWindowWhen750%60%7719194411
SinkEmptyMulticast.VoidInner750%120%151529299911
ParallelDoOnEach.DoOnEachSignalPeek750%60%15151313121211
FluxDefaultIfEmpty.DefaultIfEmptySubscriber750%100%141426269911
FluxGroupBy740%40%6616164411
FluxWindowWhen.WindowWhenOpenSubscriber730%100%131326268811
FluxBufferWhen730%40%6616164411
InternalEmptySink720%150%111122222211
FluxUsingWhen.CommitInner720%80%111121217711
ParallelMergeOrdered720%80%8816164411
MonoSequenceEqual720%60%6615153311
MonoElementAt720%60%7715154411
FluxConcatMap.ConcatMapInner720%80%101022226611
Operators.new Fuseable.ConditionalSubscriber() {...}710%n/a7717177711
FluxPeekFuseable710%40%12122121101011
FluxDistinct710%40%5512123311
FluxWindowPredicate710%40%6616164411
ParallelMergeSequential700%80%8817174411
MonoCacheInvalidateWhen.TriggerSubscriber700%120%131317177711
FluxFromMonoOperator690%100%101026265511
MonoRepeatWhen690%40%5520203311
FluxSubscribeOn690%60%6617173311
FluxHide.SuppressFuseableSubscriber690%60%17172626141411
MonoIgnoreThen690%0%5517174411
FluxRepeatWhen690%40%5520203311
MonoFromFluxOperator680%100%101026265511
FluxSubscribeOnValue670%80%7720203311
FluxZip.PairwiseZipper670%0%4413133311
MonoSubscribeOnValue670%80%7720203311
InternalConnectableFluxOperator670%100%101026265511
FluxErrorOnRequest.ErrorSubscription660%140%131318186611
MonoFromPublisher660%80%101025256611
MonoLiftFuseable660%100%9914144411
ParallelFluxHide660%100%101017175511
FluxLiftFuseable660%100%9915154411
MonoPublishMulticast.PublishMulticastInner650%120%121220206611
InternalFluxOperator650%100%101025255511
MonoTimeout650%0%7716166611
FluxRepeatWhen.RepeatWhenOtherSubscriber650%60%14142020111111
FluxRetryWhen.RetryWhenOtherSubscriber650%60%14142020111111
MonoCallable650%60%9922226611
MonoExpand640%40%5517173311
FluxDoOnEach640%80%8813134411
FluxExpand640%40%5517173311
FluxConcatMapNoPrefetch.FluxConcatMapNoPrefetchSubscriber.State640%n/a11771111
MonoErrorSupplied630%40%8816166611
FluxStream630%0%4419193311
MonoOnAssembly620%80%9912125511
MonoIgnorePublisher610%60%9922226611
FluxSubscribeOnCallable610%60%6616163311
MonoSupplier610%60%9920206611
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
FluxSourceFuseable570%80%101017176611
FluxSource570%80%101017176611
FluxLimitRequest570%80%8813134411
MonoRunnable560%40%8821216611
MonoWhenFunctionsKt560%n/a44444411
FluxWindowBoundary550%40%6614144411
FluxLift550%60%7713134411
MonoLift550%60%7713134411
FluxArray550%80%8815154411
FluxCreate.IgnoreSink550%80%7714143311
FluxDistinctFuseable550%0%4410103311
ParallelGroup550%80%7714143311
FluxHide.HideSubscriber550%40%111120209911
FluxOnBackpressureBufferStrategy550%80%8812124411
ParallelArraySource540%100%9914144411
MonoCount.CountSubscriber540%60%9917176611
MonoHasElements.HasElementsSubscriber540%60%9918186611
MonoPublishMulticast540%40%5511113311
FluxSink.OverflowStrategy540%n/a11661111
FluxPublish.PublishInner530%140%111115154411
FluxTake520%60%7711114411
FluxRetry510%60%6612123311
MonoHasElement.HasElementSubscriber510%60%9919196611
FluxBufferPredicate510%0%5511114411
FluxSourceMonoFuseable500%40%66884411
ParallelMergeSort500%60%7714144411
InternalMonoOperator500%60%7722224411
FluxSourceMono500%40%66884411
MonoSource500%60%9918186611
MonoSourceFuseable500%60%9918186611
FluxOnBackpressureBufferTimeout500%40%7713135511
FluxCallableOnAssembly490%60%9910106611
FluxZipIterable490%40%5512123311
OnNextFailureStrategy.ResumeDropStrategy480%100%8815153311
FluxSampleFirst.SampleFirstOther480%60%101017177711
OnNextFailureStrategy.ResumeStrategy480%80%7714143311
NextProcessor.NextInner480%100%101017175511
FluxTakeLast470%60%7711114411
FluxConcatIterable470%40%5515153311
FluxDistinctUntilChanged470%40%55993311
FluxBufferBoundary.BufferBoundaryOther460%60%101018187711
FluxRepeat460%60%6612123311
MonoRepeat460%60%6612123311
FluxWithLatestFrom460%0%4411113311
FluxWindowBoundary.WindowBoundaryOther460%60%101018187711
FluxCallable460%40%6616164411
FluxDelaySubscription.DelaySubscriptionMainSubscriber460%40%9916167711
FluxScanSeed460%40%5511113311
ContextTrackingFunctionWrapper.new CorePublisher() {...}460%0%44993311
MonoDelayElement450%40%55993311
SinksSpecs.UnicastSpecImpl450%0%7714146611
FluxWithLatestFrom.WithLatestFromOtherSubscriber450%40%9918187711
FluxSampleTimeout450%0%5511114411
FluxUsingWhen.CancelInner450%60%101015157711
FluxConcatMapNoPrefetch440%40%6610104411
FluxMapSignal440%80%7710103311
UnicastManySinkNoBackpressure.State440%n/a11551111
MonoSingle440%40%6612124411
MonoRetry440%60%6612123311
FluxErrorSupplied430%40%6612124411
FluxOnBackpressureBuffer430%40%6611114411
FluxBufferPredicate.ChangedPredicate430%40%5513133311
FluxSwitchIfEmpty.SwitchIfEmptySubscriber420%60%7714144411
MonoFlatMap420%40%5510103311
FluxIndex.NullSafeIndexMapper420%40%5510103311
MonoUsingWhen.MonoUsingWhenSubscriber420%0%5513134411
FluxSample410%0%5511114411
FluxDelaySubscription410%0%6610105511
MonoError410%40%8812126611
SinksSpecs.AbstractSerializedSink410%60%6611113311
ParallelMergeReduce410%40%5512123311
FluxDeferContextual410%0%4413133311
FluxIndex0%40%55993311
FluxIndexFuseable0%40%55993311
MonoStreamCollector0%0%4410103311
ParallelMergeReduce.SlotPair0%60%7712124411
MonoDeferContextual0%0%4413133311
FluxTimeout.TimeoutOtherSubscriber0%0%8815157711
FluxMap0%40%55993311
MonoDelaySubscription0%0%55994411
FluxMapFuseable0%40%55993311
FluxSkip0%40%55883311
FluxHandle0%40%55993311
MonoMapFuseable0%40%55993311
FluxTakeFuseable0%40%55883311
FluxHandleFuseable0%40%55993311
FluxOnBackpressureDrop0%0%8812127711
MonoReduceSeed0%0%44883311
MonoMap0%40%55993311
MonoCreate0%0%5514144411
FluxRefCountGrace.RefConnection0%60%8811115511
MonoCollect0%0%44883311
MonoPeekTerminal0%40%5510103311
MonoRepeatPredicate0%40%5510103311
FluxRepeatPredicate0%40%5510103311
Sinks.EmissionException0%n/a44994411
FluxDefer0%0%4412123311
FluxMetricsFuseable0%0%44883311
MonoNameFuseable0%80%7712123311
FluxNameFuseable0%80%7712123311
OnNextFailureStrategy0%n/a77887711
MonoFilterFuseable0%40%55883311
FluxSkipLast0%40%55883311
MonoFilter0%40%55883311
MonoMetricsFuseable0%0%44883311
FluxDoFinally0%40%66994411
MonoJust0%40%8811116611
FluxFilter0%40%55883311
FluxFilterFuseable0%40%55883311
FluxTakeUntilOther0%0%5510104411
FluxDelaySequence0%40%55993311
MonoMetrics0%0%44883311
FluxConcatMap.WeakScalarSubscription0%40%5512123311
ParallelThen0%40%5510103311
FluxLog0%40%55993311
MonoDefer0%0%4412123311
FluxCreate.NoOverflowBaseAsyncSink0%40%4411112211
MonoLog0%40%55993311
FluxWindowTimeout.WindowTimeoutSubscriber.ConsumerIndexHolder0%40%4413132211
Operators.CorePublisherAdapter0%0%7715156611
Operators.ConditionalSubscriberAdapter0%n/a7714147711
FluxSkipUntilOther0%0%44993311
MonoTakeUntilOther0%0%44993311
ConnectableFluxHide0%60%8810105511
FluxReplay.SizeAndTimeBoundReplayBuffer.TimedNode0%n/a22662211
MonoLogFuseable0%40%55883311
FluxConcatMap.ErrorMode0%n/a11441111
FluxBufferPredicate.Mode0%n/a11221111
MonoFlatMapMany0%40%55883311
BufferOverflowStrategy0%n/a11441111
FluxLogFuseable0%40%55883311
EmitterProcessor.EmitterDisposable0%100%8810103311
Operators.EmptySubscription0%0%12121313111111
MonoTakeLastOne0%0%55994411
SinkOneSerialized0%40%44992211
FluxSampleFirst0%0%55994411
FluxError0%40%6610104411
MonoContextWrite0%0%44773311
FluxCancelOn0%40%55773311
FluxContextWrite0%0%44773311
FluxJust0%40%66994411
OnNextFailureStrategy.LambdaOnNextErrorStrategy0%0%55884411
MonoCacheInvalidateIf.CacheMonoSubscriber0%60%6610103311
MonoSwitchIfEmpty0%0%44883311
MonoCacheInvalidateWhen.CacheMonoSubscriber0%60%6610103311
FluxSwitchIfEmpty0%0%44883311
FluxOnAssembly.CheckpointLightSnapshot0%0%55664411
Flux.new Predicate() {...}0%40%44222211
MonoPublishOn0%40%55773311
FluxOnErrorReturn0%0%44773311
MonoOnErrorReturn0%0%44773311
MonoCancelOn0%40%55773311
SinkOneMulticast.NextInner0%40%6611114411
MonoTimed0%40%55773311
FluxElapsed0%40%55773311
MonoElapsed0%40%55773311
FluxFilterWhen0%0%44773311
Flux.new BooleanSupplier() {...}0%40%44222211
FluxRefCount.RefCountMonitor0%n/a5511115511
MonoRetryWhen0%0%44773311
MonoEmpty0%0%9911118811
SourceProducer0%40%44442211
MonoDoOnEach0%0%44663311
MonoHandleFuseable0%0%44663311
MonoReduce0%0%44663311
FluxSkipWhile0%0%44663311
MonoOnErrorResume0%0%44663311
MonoHandle0%0%44663311
FluxSkipUntil0%0%44663311
FluxOnErrorResume0%0%44663311
FluxTakeUntil0%0%44663311
MonoDoOnEachFuseable0%0%44663311
FluxScan0%0%44663311
MonoAny0%0%44663311
MonoAll0%0%44663311
FluxTakeWhile0%0%44663311
FluxDoOnEachFuseable0%0%44663311
BlockingFirstSubscriber0%40%6611114411
MonoDefaultIfEmpty0%0%44663311
FluxTimed0%0%55774411
FluxDefaultIfEmpty0%0%44663311
MonoCacheTime.CacheMonoSubscriber0%40%55993311
FluxOnAssembly.CheckpointHeavySnapshot0%0%33332211
FluxCreate.CreateMode0%n/a11221111
FluxErrorOnRequest0%0%44773311
MonoCurrentContext0%0%55774411
FluxDoOnEach.DoOnEachFuseableConditionalSubscriber0%0%33772211
FluxCreate.SinkDisposable0%40%5510103311
BlockingMonoSubscriber0%40%6610104411
FluxOperator0%40%44662211
MonoFilterWhen0%0%44663311
FluxSwitchOnFirst.SwitchOnFirstConditionalControlSubscriber0%0%33772211
FluxDoOnEach.DoOnEachConditionalSubscriber0%0%33772211
FluxTakeLastOne0%0%55664411
Sinks.OptimisticEmitFailureHandler0%40%44442211
MonoOperator0%40%44662211
FluxNever0%0%66885511
MonoCompletionStage.new Operators.MonoSubscriber() {...}0%0%33552211
Operators.DrainSubscriber0%n/a77997711
FluxReplay.SizeBoundReplayBuffer.Node0%n/a22552211
MonoNever0%0%66885511
FluxDoFirst0%0%44773311
MonoDoFirst0%0%44773311
FluxSwitchOnFirst.SwitchOnFirstMain0%n/a44774411
FluxDoFirstFuseable0%0%44773311
MonoDoFinally0%0%44663311
MonoDoFirstFuseable0%0%44773311
FluxDelaySequence.DelaySubscriber.OnError0%n/a22662211
Operators.CancelledSubscription0%0%77886611
MonoSingleMono0%0%44553311
FluxOnBackpressureLatest0%0%55664411
MonoDematerialize0%0%44553311
FluxCreate.ErrorAsyncSink0%n/a33553311
EmitterProcessor.EmitterInner0%n/a33883311
FluxDematerialize0%0%44553311
MonoSourceFlux0%0%44663311
FluxEmpty0%0%66775511
MonoSourceFluxFuseable0%0%44663311
MonoIgnoreElement0%0%44553311
FluxHide0%0%44553311
BlockingLastSubscriber0%n/a44884411
MonoHide0%0%44553311
MonoCollectList0%0%44553311
FluxDetach0%0%44553311
MonoIgnoreElements0%0%44553311
MonoHasElements0%0%44553311
MonoCount0%0%44553311
MonoHasElement0%0%44553311
MonoMaterialize0%0%44553311
MonoDetach0%0%44553311
FluxMaterialize0%0%44553311
MonoNext0%0%44553311
FluxTimeout.CancelledIndexedCancellable0%n/a33443311
Flux.new Function() {...}0%n/a22442211
OnNextFailureStrategy.new OnNextFailureStrategy() {...}0%n/a33663311
FluxUsingWhen.UsingWhenConditionalSubscriber0%n/a22442211
FluxCreate.DropAsyncSink0%n/a33443311
SerializedSubscriber.LinkedArrayNode0%n/a11551111
FluxOnAssembly.MethodReturnSnapshot0%n/a33553311
FluxDelaySequence.DelaySubscriber.OnComplete0%n/a22442211
FluxOnAssembly.OnAssemblyConditionalSubscriber0%n/a22442211
FluxCombineLatest.SourceAndArray0%n/a22552211
MonoCacheInvalidateIf.ValueState0%n/a33663311
SinksSpecs0%n/a22332211
Sinks0%n/a44444411
MonoRunnable.MonoRunnableEagerSubscription0%n/a44554411
FluxDoFinally.DoFinallyConditionalSubscriber0%n/a22332211
FluxExtensionsKt.toFlux.new Iterable() {...}0%n/a22222211
MonoBridges0%n/a33333311
Sinks.EmitFailureHandler0%n/a33223311
MonoWhenFunctionsKt.zip.new Function() {...}0%n/a11111111
MonoExtensionsKt.doOnError.new Consumer() {...}0%n/a11111111
FluxExtensionsKt.toIterable.new Iterable() {...}0%n/a22222211
MonoExtensionsKt.onErrorMap.new Function() {...}0%n/a11111111
FluxExtensionsKt.doOnError.new Consumer() {...}0%n/a11111111
FluxExtensionsKt.onErrorResume.new Function() {...}0%n/a11111111
FluxExtensionsKt.onErrorMap.new Function() {...}0%n/a11111111
MonoExtensionsKt.onErrorResume.new Function() {...}0%n/a11111111
FluxWindowWhen.WindowOperation0%n/a11441111
InnerProducer0%0%22331111
QueueDrainSubscriberWip0%n/a11221111
QueueDrainSubscriberPad30%n/a22332211
Traces.SharedSecretsCallSiteSupplierFactory0%n/a22222211
Traces.ExceptionCallSiteSupplierFactory0%n/a22222211
MonoCacheInvalidateIf.new MonoCacheInvalidateIf.State() {...}0%n/a33333311
FluxExtensionsKt.switchIfEmpty.new Supplier() {...}0%n/a11111111
MonoExtensionsKt.switchIfEmpty.new Supplier() {...}0%n/a11111111
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
FluxExtensionsKt.split.new Function() {...}0%n/a11111111