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
Flux.java4,8750%2560%61161188588548348366
FluxWindowTimeout.java3,5290%6500%413413955955888855
Operators.java3,0280%5180%4674679319312082081414
Mono.java2,9100%1760%34734748448425925933
FluxReplay.java2,6680%4320%32932976876811311388
FluxFlatMap.java2,0230%3600%230230560560505044
FluxPublishOn.java1,8470%2920%196196553553505033
FluxZip.java1,8190%2560%192192490490646477
FluxSwitchOnFirst.java1,6030%2960%209209414414616166
FluxSwitchMapNoPrefetch.java1,4780%2560%173173399399454533
FluxCreate.java1,4180%2270%20520541741790901212
FluxPeekFuseable.java1,3660%1940%149149453453525244
FluxConcatMap.java1,3510%2050%146146367367434366
FluxWindowPredicate.java1,3260%2340%168168409409515133
FluxPublishMulticast.java1,2390%1860%148148370370555555
FluxFlattenIterable.java1,2070%1760%111111385385232322
FluxWindow.java1,1990%1880%139139327327454544
FluxGroupBy.java1,1880%1980%147147366366484833
FluxHandleFuseable.java1,1670%1700%130130377377454533
FluxOnAssembly.java1,0770%1120%119119256256636399
FluxPublish.java1,0760%2060%139139287287363644
FluxBufferWhen.java9990%1360%107107285285393944
EmitterProcessor.java9890%1880%136136270270424233
FluxCombineLatest.java9880%1260%103103288288404044
SinkManyEmitterProcessor.java9860%1940%133133268268363633
ParallelFlux.java9410%420%101101171171808011
FluxMergeComparing.java9160%1340%9393226226262633
FluxGroupJoin.java9120%940%8484249249373744
FluxBuffer.java9110%1220%9696236236353544
FluxMergeSequential.java9070%1560%112112262262343433
FluxIterable.java8920%1500%110110314314353533
MonoZip.java8820%1420%107107221221363633
FluxDistinct.java8420%800%7878245245383844
SignalLogger.java8310%1500%101101142142262611
ParallelSource.java8270%1240%8686241241242433
MonoDelayUntil.java8180%1400%109109242242393933
NextProcessor.java8160%1510%112112228228333322
FluxFilterWhen.java8080%1280%9494234234303033
FluxConcatArray.java7980%1140%8989230230323233
FluxSwitchMap.java7950%1280%100100233233363633
FluxUsingWhen.java7530%840%9090199199484877
FluxJoin.java7500%720%5353213213171722
FluxTake.java7450%1180%9999220220404044
FluxUsing.java7370%1020%103103205205525244
FluxHandle.java7310%1020%8686226226353533
FluxExpand.java7120%1060%8888227227353544
UnicastProcessor.java7090%1200%104104221221444411
Hooks.java6940%380%6161208208424211
MonoWhen.java6930%1160%9393177177353533
ParallelMergeSequential.java6920%1280%9393196196292933
FluxWindowWhen.java6780%900%8080212212353555
FluxBufferPredicate.java6680%980%7979177177303044
FluxFilterFuseable.java6620%920%7979207207333333
Traces.java6290%960%7373147147252566
FluxBufferTimeout.java6080%920%6767166166212122
SinkManyUnicast.java6070%1140%8787187187303011
MonoSequenceEqual.java6030%960%7070167167222233
MonoCacheInvalidateWhen.java5990%880%7676159159323244
FluxOnBackpressureBuffer.java5930%1160%8181178178232322
FluxWindowBoundary.java5900%780%6969179179303033
FluxArray.java5890%940%7575165165282833
MonoCacheTime.java5820%720%6666163163303033
FluxTimeout.java5760%640%7171166166393955
SinkManyReplayProcessor.java5760%640%8484156156525222
FluxFirstWithValue.java5750%660%5555154154222233
ReplayProcessor.java5660%600%8484155155545422
FluxOnBackpressureBufferTimeout.java5600%880%6363173173191922
FluxRange.java5530%940%7474154154272733
SinkManyBestEffort.java5520%1000%7676157157262622
ParallelMergeReduce.java5440%860%7474148148313144
MonoPeekTerminal.java5430%900%6565154154202022
FluxSampleTimeout.java5420%740%6666157157292933
FluxMetrics.java5390%260%3535129129222222
MonoPublishMulticast.java5340%900%6868160160232333
FluxGenerate.java5290%760%6666167167282822
ParallelMergeSort.java5290%860%6767157157242433
MonoCacheInvalidateIf.java5280%780%6565143143262655
FluxOnBackpressureBufferStrategy.java5280%970%6767167167181822
FluxConcatMapNoPrefetch.java5260%740%5858134134191933
FluxMapFuseable.java5130%620%6363148148323233
MonoUsing.java5100%820%6060139139191922
MonoFilterWhen.java4970%880%7474136136303033
FluxFirstWithSignal.java4950%680%5454139139202033
MonoIgnoreThen.java4900%800%6363154154232322
MonoCreate.java4830%980%7070142142212122
SerializedSubscriber.java4800%800%5454146146141422
FluxBufferBoundary.java4790%620%5656141141252533
FluxDoOnEach.java4760%660%6464137137313155
FluxIndexFuseable.java4720%500%5757136136323233
ParallelThen.java4410%780%7070107107313133
FluxDistinctUntilChanged.java4350%440%4545129129232333
DirectProcessor.java4210%580%5555117117242411
MonoFlatMap.java4150%600%6161122122313133
FluxFilter.java4150%520%4949130130232333
MonoDelay.java4140%940%6969107107222222
FluxMapSignal.java4130%540%4646106106191922
FluxRefCountGrace.java4120%600%5757117117272733
FluxSubscribeOnCallable.java4110%840%6060122122181822
FluxMap.java3890%460%4545109109222233
FluxTap.java3890%220%3030141141191933
FluxPeek.java3860%460%4545129129222222
QueueDrainSubscriber.java3810%780%6262116116232366
FluxIndex.java3790%380%4444109109252544
SinksSpecs.java3690%140%66669797595955
FluxSample.java3690%600%5757111111272733
FluxRefCount.java3670%520%5252101101262633
FluxSubscribeOnValue.java3660%720%6262103103262633
BlockingIterable.java3540%460%41419999181822
FluxRetryWhen.java3530%300%4747102102323233
DrainUtils.java3520%620%383897977711
FluxWithLatestFrom.java3490%500%5151114114262633
FluxOnBackpressureLatest.java3390%700%5151100100161622
SinkEmptyMulticast.java3360%500%46469797212122
MonoReduce.java3350%440%40409999181822
FluxTapFuseable.java3350%380%3434106106151533
FluxSampleFirst.java3280%440%4848100100262633
FluxOnErrorReturn.java3230%620%45458383141422
MonoDelayElement.java3190%500%44448888191922
MonoUsingWhen.java3160%300%32328484171733
FluxScanSeed.java3010%360%35359393171733
MonoFlatMapMany.java3000%380%41419191222233
FluxTakeUntilOther.java2970%520%51519292252533
ParallelReduceSeed.java2930%400%33338585131322
FluxSubscribeOn.java2930%420%37377979161622
FluxSkipUntilOther.java2910%400%42428787222233
FluxMaterialize.java2840%480%45456969212122
FluxTimed.java2840%300%36366666212133
FluxRepeatWhen.java2830%240%39398585272733
SinkManyUnicastNoBackpressure.java2810%430%41416868151522
ParallelCollect.java2770%340%30307979131322
FluxDelaySequence.java2730%320%35356767191944
MonoSubscribeOn.java2670%340%33337575161622
MonoMetricsFuseable.java2660%360%31316262131322
MonoStreamCollector.java2560%220%22228181111122
MonoTakeLastOne.java2490%360%30307575121222
BlockingOptionalMonoSubscriber.java2450%400%32326666121211
FluxMetricsFuseable.java2390%280%25255454111122
StateLogger.java2330%120%121242426611
MonoFirstWithValue.java2320%180%151576766611
StrictSubscriber.java2320%420%31316868101011
FluxZipIterable.java2280%200%22226868121222
FluxTakeLast.java2240%280%38386565242433
MonoPublishOn.java2200%340%32326464151522
FluxSkipUntil.java2180%260%26267070131322
FluxSkipWhile.java2180%260%26267070131322
FluxLimitRequest.java2170%320%30306464141422
LambdaMonoSubscriber.java2170%360%30307373121211
MonoCollect.java2160%180%20206868111122
BlockingSingleSubscriber.java2150%360%272755559911
FluxOnBackpressureDrop.java2110%260%30306565171722
SinkOneMulticast.java2110%340%28285252111122
MonoReduceSeed.java2110%200%20206060101022
MonoSingle.java2090%300%28286565131322
ParallelGroup.java2080%320%31316060151522
FluxDefaultIfEmpty.java2060%420%33335858121222
MonoElementAt.java2040%180%19195252101022
ImmutableSignal.java2030%330%29294646111111
MonoMetrics.java2030%140%19195353121222
FluxDelaySubscription.java1970%220%32326262212133
FluxInterval.java1930%240%22224747101022
LambdaSubscriber.java1890%320%27275959111111
MonoFirstWithSignal.java1840%160%131363635511
MonoName.java1830%240%171742425511
FluxName.java1830%240%171742425511
OnNextFailureStrategy.java1820%200%30305050202055
ParallelDoOnEach.java1770%180%26263838171722
Sinks.java1770%120%24243232181855
FluxContextWrite.java1760%260%32325252191922
MonoCollectList.java1730%220%21215353101022
FluxElapsed.java1720%180%27275252181822
FluxScan.java1700%220%23235050121222
BaseSubscriber.java1700%140%27276363202011
FluxDematerialize.java1680%320%28285252121222
Signal.java1640%360%35352828171711
MonoMaterialize.java1630%260%26265252131322
FluxConcatIterable.java1620%220%191957578822
FluxDoFinally.java1600%180%26264848171733
OperatorDisposables.java1580%340%262650509911
FluxMerge.java1530%120%101030304411
FluxTakeWhile.java1500%180%21214848121222
FluxDetach.java1500%300%28284545131322
FluxTakeUntil.java1490%180%21214747121222
FluxProcessor.java1490%260%33333636202011
MonoCallable.java1480%180%25255252161622
FluxSkipLast.java1470%160%20203838121222
MonoCompletionStage.java1460%220%25255151141422
FluxHide.java1420%120%32325151262633
FluxCancelOn.java1410%180%23234040141422
MonoSupplier.java1400%180%25254848161622
FluxRetry.java1400%200%191941419922
ParallelFluxName.java1390%180%161634347711
MonoProcessor.java1360%220%31313131202011
FluxRepeat.java1340%200%191941419922
ParallelPeek.java1340%120%19193636131311
MonoSingleCallable.java1310%220%181840407711
ParallelRunOn.java1300%140%121226265511
SignalType.java1290%100%111122222211
MonoNext.java1290%180%22224242131322
FluxSkip.java1290%120%18183737121222
FluxRepeatPredicate.java1270%160%171740409922
SinkManySerialized.java1270%120%17173131111111
InternalManySink.java1260%250%191939393311
ContextTrackingFunctionWrapper.java1220%0%9924247722
MonoAny.java1220%120%151538389922
MonoAll.java1220%120%151538389922
DelegateProcessor.java1190%100%18183232131311
ParallelFluxOnAssembly.java1150%160%151527277711
ParallelLiftFuseable.java1140%160%141433336611
ParallelConcatMap.java1040%140%121222225511
FluxOnErrorResume.java1030%100%131332328822
ParallelFlatMap.java1020%120%111124245511
ParallelLift.java950%120%121227276611
ConnectableFlux.java930%0%15151919131311
GroupedLiftFuseable.java920%140%131325256611
ParallelLog.java910%120%111121215511
FluxErrorOnRequest.java900%160%171725259922
MonoToCompletableFuture.java890%140%141428287711
MonoFlattenIterable.java890%80%8821214411
ConnectableLiftFuseable.java890%140%131320206611
ParallelMap.java870%120%101020204411
ParallelFilter.java870%120%101020204411
MonoHasElement.java860%100%141429299922
FluxAutoConnect.java860%140%121219195511
FluxAutoConnectFuseable.java860%140%121219195511
SinkEmptySerialized.java830%80%121222228811
MonoHasElements.java810%100%141427279922
GroupedLift.java810%100%111123236611
MonoCallableOnAssembly.java800%80%121217178811
MonoIgnoreElements.java780%80%16162626121222
ConnectableLift.java780%100%111118186611
MonoTap.java730%60%6621213311
MonoTapFuseable.java730%60%6621213311
FluxSwitchIfEmpty.java730%80%111122227722
InternalEmptySink.java720%150%111122222211
ParallelMergeOrdered.java710%80%8816164411
FluxFromMonoOperator.java690%100%101026265511
MonoRepeatWhen.java690%0%5520203311
MonoFromFluxOperator.java680%100%101026265511
MonoRunnable.java670%0%12122626101022
MonoSubscribeOnValue.java670%80%7720203311
InternalConnectableFluxOperator.java670%100%101026265511
ParallelFluxHide.java660%100%101017175511
MonoLiftFuseable.java660%100%9914144411
FluxLiftFuseable.java660%100%9915154411
MonoFromPublisher.java660%80%101025256611
MonoTimeout.java650%0%7716166611
InternalFluxOperator.java650%100%101025255511
MonoExpand.java640%0%5517173311
FluxStream.java640%0%4419193311
MonoErrorSupplied.java630%0%8816166611
MonoOnAssembly.java620%80%9912125511
MonoIgnorePublisher.java610%60%9922226611
InternalOneSink.java600%120%9920201111
ConnectableFluxOnAssembly.java600%100%111113136611
MonoPeek.java590%0%12121818101011
MonoPeekFuseable.java590%0%12121818101011
MonoSubscribeOnCallable.java590%60%6615153311
FluxSink.java570%n/a22772222
FluxSource.java570%80%101017176611
FluxSourceFuseable.java570%80%101017176611
MonoCount.java560%0%111117179922
FluxLift.java550%60%7713134411
MonoLift.java550%60%7713134411
FluxDistinctFuseable.java550%0%4410103311
ParallelArraySource.java540%100%9914144411
FluxSourceMono.java500%0%66884411
MonoSourceFuseable.java500%60%9918186611
FluxSourceMonoFuseable.java500%0%66884411
MonoSource.java500%60%9918186611
InternalMonoOperator.java500%60%7722224411
FluxCallableOnAssembly.java490%60%9910106611
MonoRepeat.java460%60%6612123311
MonoRetry.java440%60%6612123311
FluxErrorSupplied.java430%0%6612124411
FluxDeferContextual.java410%0%4413133311
MonoError.java410%0%8812126611
MonoMap.java0%0%55993311
MonoMapFuseable.java0%0%55993311
FluxTakeFuseable.java0%0%55883311
MonoDelaySubscription.java0%0%55994411
MonoDeferContextual.java0%0%4413133311
MonoRepeatPredicate.java0%0%5510103311
MonoNameFuseable.java0%80%7712123311
MonoFilter.java0%0%55883311
MonoFilterFuseable.java0%0%55883311
MonoJust.java0%0%8811116611
FluxNameFuseable.java0%80%7712123311
FluxDefer.java0%0%4412123311
MonoLog.java0%0%55993311
FluxLog.java0%0%55993311
MonoDefer.java0%0%4412123311
ConnectableFluxHide.java0%60%8810105511
MonoTakeUntilOther.java0%0%44993311
MonoLogFuseable.java0%0%55883311
FluxLogFuseable.java0%0%55883311
BufferOverflowStrategy.java0%n/a11441111
SinkOneSerialized.java0%0%44992211
MonoContextWrite.java0%0%44773311
FluxError.java0%0%6610104411
FluxJust.java0%0%66994411
MonoSwitchIfEmpty.java0%0%44883311
MonoOnErrorReturn.java0%0%44773311
MonoElapsed.java0%0%55773311
MonoTimed.java0%0%55773311
MonoCancelOn.java0%0%55773311
MonoRetryWhen.java0%0%44773311
MonoEmpty.java0%0%9911118811
SourceProducer.java0%0%44442211
FluxDoOnEachFuseable.java0%0%44663311
MonoHandle.java0%0%44663311
MonoDoOnEach.java0%0%44663311
MonoHandleFuseable.java0%0%44663311
FluxCallable.java0%0%55884411
MonoDoOnEachFuseable.java0%0%44663311
MonoOnErrorResume.java0%0%44663311
MonoDefaultIfEmpty.java0%0%44663311
BlockingFirstSubscriber.java0%0%6611114411
MonoCurrentContext.java0%0%55774411
FluxOperator.java0%0%44662211
BlockingMonoSubscriber.java0%0%6610104411
FluxTakeLastOne.java0%0%55664411
FluxNever.java0%0%66885511
MonoOperator.java0%0%44662211
MonoNever.java0%0%66885511
MonoDoFirst.java0%0%44773311
FluxDoFirst.java0%0%44773311
MonoDoFirstFuseable.java0%0%44773311
FluxDoFirstFuseable.java0%0%44773311
MonoDoFinally.java0%0%44663311
MonoSingleMono.java0%0%44553311
MonoSourceFlux.java0%0%44663311
MonoDematerialize.java0%0%44553311
FluxEmpty.java0%0%66775511
MonoSourceFluxFuseable.java0%0%44663311
BlockingLastSubscriber.java0%n/a44884411
MonoDetach.java0%0%44553311
MonoIgnoreElement.java0%0%44553311
MonoHide.java0%0%44553311
MonoBridges.java0%n/a33333311
InnerProducer.java0%0%22331111
SignalPeek.java0%n/a22222211
InnerOperator.java0%n/a11111111
GroupedFlux.java0%n/a11111111
SynchronousSink.java0%n/a11111111
MonoSink.java0%n/a11111111