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
Flux.java4,8880%2620%61461489289248348344
FluxWindowTimeout.java3,5280%6500%413413955955888855
Mono.java2,9280%1760%35135148748726326311
Operators.java2,8590%4880%4414418798791971971313
FluxReplay.java2,6680%4320%32932976876811311388
FluxFlatMap.java2,0260%3600%230230561561505044
FluxZip.java1,8730%2700%191191507507565666
FluxPublishOn.java1,8470%2920%196196553553505033
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
FluxFlattenIterable.java1,3300%1940%123123408408262622
FluxWindowPredicate.java1,3250%2340%168168409409515133
FluxPublishMulticast.java1,2390%1860%148148370370555555
FluxWindow.java1,1960%1880%139139327327454544
FluxGroupBy.java1,1880%1980%147147366366484833
FluxHandleFuseable.java1,1670%1700%130130377377454533
FluxPublish.java1,1060%2160%144144295295363644
FluxOnAssembly.java1,0770%1120%119119256256636399
FluxIterable.java1,0180%1660%123123361361404033
FluxBufferWhen.java9990%1360%107107285285393944
EmitterProcessor.java9890%1880%136136270270424233
FluxCombineLatest.java9880%1260%103103288288404044
FluxMergeComparing.java9430%1460%9999229229262633
ParallelFlux.java9410%420%101101171171808011
FluxMergeSequential.java9190%1580%113113265265343433
FluxGroupJoin.java9120%940%8484249249373744
FluxBuffer.java9110%1220%9696236236353544
FluxDistinct.java8420%800%7878245245383844
SignalLogger.java8310%1500%101101142142262611
ParallelSource.java8270%1240%8686241241242433
MonoDelayUntil.java8180%1400%109109242242393933
FluxFilterWhen.java8080%1280%9494234234303033
FluxConcatArray.java7980%1140%8989230230323233
FluxSwitchMap.java7950%1280%100100233233363633
NextProcessor.java7680%1370%102102218218303022
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
ParallelMergeSequential.java6920%1280%9393196196292933
FluxWindowWhen.java6770%900%8080212212353555
FluxBufferPredicate.java6680%980%7979177177303044
FluxFilterFuseable.java6620%920%7979207207333333
MonoZip.java6460%900%6767168168222233
Traces.java6290%960%7373147147252566
FluxBufferTimeout.java6080%920%6767166166212122
MonoSequenceEqual.java6030%960%7070167167222233
MonoCacheInvalidateWhen.java5990%880%7676159159323244
FluxOnBackpressureBuffer.java5930%1160%8181178178232322
FluxArray.java5890%940%7575165165282833
FluxWindowBoundary.java5890%780%6969179179303033
MonoCacheTime.java5820%720%6666163163303033
FluxTimeout.java5760%640%7171166166393955
FluxFirstWithValue.java5750%660%5555154154222233
ReplayProcessor.java5660%600%8484155155545422
FluxOnBackpressureBufferTimeout.java5600%880%6363173173191922
FluxMetrics.java5560%260%3535131131222222
FluxRange.java5530%940%7474154154272733
SinkManyBestEffort.java5520%1000%7676157157262622
MonoPeekTerminal.java5430%900%6565154154202022
FluxSampleTimeout.java5420%740%6666157157292933
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
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
ParallelMergeReduce.java4610%720%5959125125232344
MonoWhen.java4440%640%5454124124222233
FluxDistinctUntilChanged.java4350%440%4545129129232333
DirectProcessor.java4210%580%5555117117242411
FluxFilter.java4150%520%4949130130232333
MonoDelay.java4140%940%6969107107222222
FluxMapSignal.java4130%540%4646106106191922
FluxRefCountGrace.java4120%600%5757117117272733
FluxSubscribeOnCallable.java4110%840%6060122122181822
FluxMap.java3890%460%4545109109222233
FluxPeek.java3860%460%4545129129222222
MonoFilterWhen.java3810%660%5656108108232333
QueueDrainSubscriber.java3810%780%6262116116232366
SinkEmptyMulticast.java3790%620%5353110110222222
FluxIndex.java3790%380%4444109109252544
FluxSample.java3690%600%5757111111272733
FluxRefCount.java3670%520%5252101101262633
FluxSubscribeOnValue.java3660%720%6262103103262633
SinksSpecs.java3660%140%6666100100595955
BlockingIterable.java3540%460%41419999181822
FluxRetryWhen.java3530%300%4747102102323233
MonoFlatMap.java3520%460%4646106106232333
DrainUtils.java3520%620%383897977711
FluxWithLatestFrom.java3490%500%5151114114262633
FluxOnBackpressureLatest.java3390%700%5151100100161622
FluxTakeUntilOther.java3320%620%5656102102252533
FluxSampleFirst.java3280%440%4848100100262633
FluxOnErrorReturn.java3230%620%45458383141422
MonoUsingWhen.java3160%300%32328484171733
FluxScanSeed.java3010%360%35359393171733
MonoFlatMapMany.java3000%380%41419191222233
FluxExtensions.kt2940%n/a30302525303088
FluxSubscribeOn.java2930%420%37377979161622
FluxSkipUntilOther.java2910%400%42428787222233
FluxMaterialize.java2840%480%45456969212122
FluxTimed.java2840%300%36366666212133
FluxRepeatWhen.java2830%240%39398585272733
UnicastManySinkNoBackpressure.java2810%430%41416868151522
FluxDelaySequence.java2730%320%35356767191944
MonoSubscribeOn.java2670%340%33337575161622
MonoMetricsFuseable.java2660%360%31316262131322
MonoCollect.java2510%280%25257777111122
BlockingOptionalMonoSubscriber.java2450%400%32326666121211
MonoElementAt.java2430%260%25256363121222
FluxMetricsFuseable.java2390%280%25255454111122
ParallelThen.java2360%360%36365858181833
StateLogger.java2330%120%121242426611
MonoFirstWithValue.java2320%180%151576766611
StrictSubscriber.java2320%420%31316868101011
FluxZipIterable.java2280%200%22226868121222
MonoStreamCollector.java2270%200%21216868111122
SinkOneMulticast.java2260%440%34346161121222
FluxTakeLast.java2240%280%38386565242433
ParallelReduceSeed.java2230%220%24246666131322
MonoPublishOn.java2200%340%32326464151522
FluxSkipWhile.java2180%260%26267070131322
FluxSkipUntil.java2180%260%26267070131322
FluxLimitRequest.java2170%320%30306464141422
LambdaMonoSubscriber.java2170%360%30307373121211
ParallelCollect.java2160%220%24246464131322
BlockingSingleSubscriber.java2150%360%272755559911
FluxOnBackpressureDrop.java2110%260%30306565171722
MonoSingle.java2090%300%28286565131322
ParallelGroup.java2080%320%31316060151522
MonoExtensions.kt2040%n/a15151111151555
MonoMetrics.java2030%140%19195353121222
ImmutableSignal.java2030%330%29294646111111
MonoCollectList.java2030%260%24246464111122
FluxDelaySubscription.java1970%220%32326262212133
FluxInterval.java1930%240%22224747101022
LambdaSubscriber.java1890%320%27275959111111
MonoDelayElement.java1890%240%23235252111122
MonoFirstWithSignal.java1840%160%131363635511
OnNextFailureStrategy.java1820%200%30305050202055
MonoReduce.java1820%200%20205656101022
MonoReduceSeed.java1770%180%20205151111122
Sinks.java1770%120%24243232181855
ParallelDoOnEach.java1770%180%26263838171722
FluxContextWrite.java1760%260%32325252191922
MonoName.java1740%240%171740405511
FluxName.java1740%240%171740405511
FluxElapsed.java1720%180%27275252181822
FluxScan.java1700%220%23235050121222
BaseSubscriber.java1700%140%27276363202011
FluxDematerialize.java1680%320%28285252121222
Signal.java1680%360%36362929181811
MonoMaterialize.java1630%260%26265252131322
FluxConcatIterable.java1620%220%191957578822
FluxDoFinally.java1600%180%26264848171733
OperatorDisposables.java1580%340%262650509911
FluxMerge.java1530%120%101030304411
FluxDetach.java1500%300%28284545131322
FluxTakeWhile.java1500%180%21214848121222
FluxTakeUntil.java1490%180%21214747121222
FluxProcessor.java1490%260%33333636202011
FluxSkipLast.java1470%160%20203838121222
MonoAny.java1450%180%19194545101022
MonoAll.java1450%180%19194545101022
FluxHide.java1420%120%32325151262633
FluxCancelOn.java1410%180%23234040141422
FluxRetry.java1400%200%191941419922
MonoProcessor.java1360%220%31313131202011
ParallelFluxName.java1350%180%161633337711
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
MonoTakeLastOne.java1280%140%17173939101022
FluxRepeatPredicate.java1270%160%171740409922
SinkManySerialized.java1270%120%17173131111111
InternalManySink.java1260%250%191939393311
MonoCompletionStage.java1260%200%161636366622
ContextTrackingFunctionWrapper.java1220%0%9924247722
DelegateProcessor.java1190%100%18183232131311
ParallelFluxOnAssembly.java1150%160%151527277711
ParallelLiftFuseable.java1140%160%141433336611
ParallelConcatMap.java1040%140%121222225511
FluxOnErrorResume.java1030%100%131332328822
ParallelFlatMap.java1020%120%111124245511
FluxDefaultIfEmpty.java1000%120%18183232121222
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
FluxAutoConnectFuseable.java860%140%121219195511
FluxAutoConnect.java860%140%121219195511
SinkEmptySerialized.java830%80%121222228811
GroupedLift.java810%100%111123236611
MonoCallableOnAssembly.java800%80%121217178811
MonoIgnoreElements.java780%80%16162626121222
ConnectableLift.java780%100%111118186611
FluxSwitchIfEmpty.java730%80%111122227722
InternalEmptySink.java720%150%111122222211
MonoCount.java720%80%131322229922
MonoHasElements.java720%80%131323239922
ParallelMergeOrdered.java720%80%8816164411
FluxFromMonoOperator.java690%100%101026265511
MonoRepeatWhen.java690%0%5520203311
MonoHasElement.java690%80%131324249922
MonoFromFluxOperator.java680%100%101026265511
MonoRunnable.java670%0%12122626101022
MonoSubscribeOnValue.java670%80%7720203311
InternalConnectableFluxOperator.java670%100%101026265511
MonoLiftFuseable.java660%100%9914144411
FluxLiftFuseable.java660%100%9915154411
MonoFunctions.kt660%n/a55445522
ParallelFluxHide.java660%100%101017175511
MonoFromPublisher.java660%80%101025256611
InternalFluxOperator.java650%100%101025255511
MonoCallable.java650%60%9922226611
MonoTimeout.java650%0%7716166611
MonoExpand.java640%0%5517173311
FluxStream.java630%0%4419193311
MonoErrorSupplied.java630%0%8816166611
MonoOnAssembly.java620%80%9912125511
MonoSupplier.java610%60%9920206611
MonoIgnorePublisher.java610%60%9922226611
InternalOneSink.java600%120%9920201111
ConnectableFluxOnAssembly.java600%100%111113136611
MonoPeekFuseable.java590%0%12121818101011
MonoSubscribeOnCallable.java590%60%6615153311
MonoPeek.java590%0%12121818101011
FluxSink.java570%n/a22772222
FluxSourceFuseable.java570%80%101017176611
FluxSource.java570%80%101017176611
MonoLift.java550%60%7713134411
FluxLift.java550%60%7713134411
FluxDistinctFuseable.java550%0%4410103311
ParallelArraySource.java540%100%9914144411
FluxSourceMono.java500%0%66884411
FluxSourceMonoFuseable.java500%0%66884411
MonoSource.java500%60%9918186611
InternalMonoOperator.java500%60%7722224411
MonoSourceFuseable.java500%60%9918186611
FluxCallableOnAssembly.java490%60%9910106611
MonoRepeat.java460%60%6612123311
FluxCallable.java460%0%6616164411
MonoRetry.java440%60%6612123311
FluxErrorSupplied.java430%0%6612124411
MonoError.java410%0%8812126611
FluxDeferContextual.java410%0%4413133311
FluxTakeFuseable.java0%0%55883311
MonoDelaySubscription.java0%0%55994411
MonoDeferContextual.java0%0%4413133311
MonoMap.java0%0%55993311
MonoMapFuseable.java0%0%55993311
MonoRepeatPredicate.java0%0%5510103311
MonoNameFuseable.java0%80%7712123311
MonoFilter.java0%0%55883311
MonoFilterFuseable.java0%0%55883311
FluxNameFuseable.java0%80%7712123311
MonoJust.java0%0%8811116611
FluxDefer.java0%0%4412123311
FluxLog.java0%0%55993311
MonoDefer.java0%0%4412123311
MonoLog.java0%0%55993311
MonoTakeUntilOther.java0%0%44993311
ConnectableFluxHide.java0%60%8810105511
FluxLogFuseable.java0%0%55883311
BufferOverflowStrategy.java0%n/a11441111
MonoLogFuseable.java0%0%55883311
SinkOneSerialized.java0%0%44992211
MonoContextWrite.java0%0%44773311
FluxError.java0%0%6610104411
FluxJust.java0%0%66994411
MonoSwitchIfEmpty.java0%0%44883311
MonoOnErrorReturn.java0%0%44773311
MonoCancelOn.java0%0%55773311
MonoElapsed.java0%0%55773311
MonoTimed.java0%0%55773311
MonoRetryWhen.java0%0%44773311
MonoEmpty.java0%0%9911118811
SourceProducer.java0%0%44442211
MonoHandle.java0%0%44663311
MonoDoOnEach.java0%0%44663311
MonoDoOnEachFuseable.java0%0%44663311
MonoOnErrorResume.java0%0%44663311
FluxDoOnEachFuseable.java0%0%44663311
MonoHandleFuseable.java0%0%44663311
MonoDefaultIfEmpty.java0%0%44663311
BlockingFirstSubscriber.java0%0%6611114411
MonoCurrentContext.java0%0%55774411
FluxOperator.java0%0%44662211
BlockingMonoSubscriber.java0%0%6610104411
FluxNever.java0%0%66885511
MonoOperator.java0%0%44662211
FluxTakeLastOne.java0%0%55664411
MonoNever.java0%0%66885511
MonoDoFirst.java0%0%44773311
FluxDoFirst.java0%0%44773311
MonoDoFinally.java0%0%44663311
MonoDoFirstFuseable.java0%0%44773311
FluxDoFirstFuseable.java0%0%44773311
MonoSingleMono.java0%0%44553311
MonoSourceFlux.java0%0%44663311
MonoSourceFluxFuseable.java0%0%44663311
MonoDematerialize.java0%0%44553311
FluxEmpty.java0%0%66775511
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
MonoSink.java0%n/a11111111
SynchronousSink.java0%n/a11111111