io.reactivex.rxjava3.internal.operators.flowable

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethodsMissedClasses
Total43,163 of 43,1630%4,942 of 4,9420%4,6024,60213,68813,6882,1282,128430430
FlowableFlatMap.MergeSubscriber1,0460%2120%125125308308191911
FlowablePublishMulticast.MulticastProcessor6540%1260%7777192192141411
FlowableJoin.JoinSubscription5900%540%4040178178131311
FlowableFlatMapMaybe.FlatMapMaybeSubscriber5890%1080%6969174174151511
FlowableFlattenIterable.FlattenIterableSubscriber5800%940%6161190190141411
FlowableGroupJoin.GroupJoinSubscription5600%540%4040165165131311
FlowableGroupBy.State5490%940%6969174174222211
FlowableCombineLatest.CombineLatestCoordinator5310%800%5656170170161611
FlowablePublish.PublishConnection5290%820%5454143143131311
FlowableWindowBoundarySelector.WindowBoundaryMainSubscriber5250%560%4343162162151511
FlowableFlatMapSingle.FlatMapSingleSubscriber5160%920%5959155155131311
FlowableMergeWithMaybe.MergeWithObserver4780%720%4949152152131311
FlowableBufferBoundary.BufferBoundarySubscriber4750%560%4040149149121211
FlowableMergeWithSingle.MergeWithObserver4720%720%4848149149121211
FlowableConcatMapEager.ConcatMapEagerDelayErrorSubscriber4620%820%5454163163131311
FlowableSwitchMap.SwitchMapSubscriber4470%880%5454154154101011
FlowableReplay.BoundedReplayBuffer4350%520%4343123123171711
FlowableCache4330%520%3939116116131311
FlowableZip.ZipCoordinator4290%780%46461281287711
FlowableWindow.WindowOverlapSubscriber4210%660%4343125125101011
FlowableGroupBy.GroupBySubscriber4120%540%3939120120121211
FlowableThrottleLatest.ThrottleLatestSubscriber3970%520%3737137137111111
FlowableObserveOn.ObserveOnSubscriber3740%540%33331291296611
FlowableWindowTimed.WindowExactBoundedSubscriber3730%520%33331051057711
FlowableObserveOn.ObserveOnConditionalSubscriber3680%540%33331271276611
FlowableReplay.ReplaySubscriber3670%460%34348787111111
FlowableOnBackpressureBufferStrategy.OnBackpressureBufferStrategySubscriber3560%570%38381351359911
FlowableWindowTimed.WindowSkipSubscriber3560%440%292997977711
FlowableWindowBoundary.WindowBoundaryMainSubscriber3350%460%3636112112131311
FlowableOnBackpressureBuffer.BackpressureBufferSubscriber3310%600%4343113113131311
FlowableConcatMapScheduler.ConcatMapImmediate3230%500%3535100100101011
FlowableBufferTimed.BufferExactBoundedSubscriber3210%200%21219898111111
FlowableSequenceEqualSingle.EqualCoordinator3200%500%32321071077711
FlowableSequenceEqual.EqualCoordinator3160%480%30301071076611
FlowableTakeLastTimed.TakeLastTimedSubscriber3100%480%34349898101011
FlowableWithLatestFromMany.WithLatestFromSubscriber2970%280%27278080131311
FlowableConcatMapScheduler.ConcatMapDelayed2930%440%313197979911
FlowableScanSeed.ScanSeedSubscriber2780%440%30301011018811
FlowableWindowTimed.WindowExactUnboundedSubscriber2730%380%252583836611
FlowableBufferTimed.BufferSkipBoundedSubscriber2670%120%16167676101011
FlowableConcatMap.ConcatMapDelayed2650%420%292989898811
FlowableSkipLastTimed.SkipLastTimedSubscriber2570%400%292989899911
FlowableConcatMap.ConcatMapImmediate2430%300%232377778811
FlowableBufferTimed.BufferExactUnboundedSubscriber2380%160%19197474111111
FlowableRefCount2360%340%232362626611
FlowableDoOnEach.DoOnEachConditionalSubscriber2340%160%151588887711
FlowableTimeout.TimeoutFallbackSubscriber2320%240%212165659911
FlowableBuffer.PublisherBufferOverlappingSubscriber2320%260%212168688811
FlowableObserveOn.BaseObserveOnSubscriber2220%400%32328484121211
FlowableDoOnEach.DoOnEachSubscriber2130%140%131380806611
FlowableBufferExactBoundary.BufferExactBoundarySubscriber2130%160%19197373111111
BlockingFlowableIterable.BlockingFlowableIterator2090%260%25256868121211
FlowableCreate.SerializedEmitter2090%440%35357575131311
FlowableReplay.SizeAndTimeBoundReplayBuffer2060%240%181856566611
FlowableGenerate.GeneratorSubscription2050%300%222274747711
FlowableWindow.WindowSkipSubscriber2040%280%222261618811
FlowableTimeout.TimeoutSubscriber1990%200%20205757101011
FlowableCreate.LatestAsyncEmitter1980%440%292970707711
AbstractBackpressureThrottlingSubscriber1970%360%262667678811
FlowableDebounceTimed.DebounceTimedSubscriber1950%260%212168688811
FlowableFlatMapCompletable.FlatMapCompletableMainSubscriber1940%200%23236161131311
FlowableCreate.BufferAsyncEmitter1920%420%282870707711
FlowableFlatMapCompletableCompletable.FlatMapCompletableMainSubscriber1880%200%191957579911
FlowableReplay1870%200%22224848121211
FlowableConcatArray.ConcatArraySubscriber1820%220%161656565511
FlowableTimeoutTimed.TimeoutFallbackSubscriber1800%140%151547478811
FlowableBuffer.PublisherBufferSkipSubscriber1780%240%191958587711
FlowableAmb.AmbCoordinator1760%260%181839395511
FlowableThrottleFirstTimed.DebounceTimedSubscriber1760%180%171761618811
FlowableReplay.UnboundedReplayBuffer1710%240%171755555511
FlowableDebounce.DebounceSubscriber1710%200%181856568811
FlowableFromIterable.IteratorConditionalSubscription1630%320%191971713311
FlowableTimeoutTimed.TimeoutSubscriber1600%100%141441419911
FlowableUsing.UsingSubscriber1600%160%161656568811
FlowableFromIterable.IteratorSubscription1590%300%181870703311
FlowablePublish1570%260%181846465511
FlowableSwitchMap.SwitchMapInnerSubscriber1570%240%191949497711
FlowableWindow.WindowExactSubscriber1550%200%181851518811
FlowableSubscribeOn.SubscribeOnSubscriber1510%180%181844449911
FlowableFromArray.ArrayConditionalSubscription1500%260%161645453311
FlowableFromArray.ArraySubscription1480%240%151545453311
FlowableSampleTimed.SampleTimedSubscriber1480%120%151548489911
FlowableSequenceEqual.EqualSubscriber1420%180%171747478811
FlowableTakeLast.TakeLastSubscriber1410%240%202051518811
FlowableBuffer.PublisherBufferExactSubscriber1390%160%151550507711
FlowableCombineLatest1370%100%8841413311
FlowableSamplePublisher.SamplePublisherSubscriber1350%100%16164444111111
FlowableBlockingSubscribe1340%140%121243435511
FlowableRetryPredicate.RetrySubscriber1330%140%131344446611
FlowableFlatMap.InnerSubscriber1320%160%161641418811
FlowableZip.ZipSubscriber1320%140%141441417711
FlowableConcatMapScheduler.BaseConcatMapSubscriber1300%120%111143435511
FlowableTake.TakeSubscriber1280%180%161642427711
FlowableZipIterable.ZipIterableSubscriber1280%100%131352528811
FlowableConcatMap.BaseConcatMapSubscriber1270%120%111142425511
FlowableDistinctUntilChanged.DistinctUntilChangedSubscriber1270%180%141443435511
FlowableDistinctUntilChanged.DistinctUntilChangedConditionalSubscriber1260%180%141442425511
FlowableDoFinally.DoFinallyConditionalSubscriber1260%180%22224545131311
FlowableCreate.BaseEmitter1230%120%23234242171711
FlowableWithLatestFrom.WithLatestFromSubscriber1230%40%12123939101011
BlockingFlowableNext.NextIterator1210%180%141437375511
FlowableDoFinally.DoFinallySubscriber1210%180%21214444121211
FlowableElementAtSingle.ElementAtSubscriber1210%140%141440407711
FlowableSingleSingle.SingleElementSubscriber1200%160%151542427711
FlowableDistinct.DistinctSubscriber1190%160%151540407711
FlowableDematerialize.DematerializeSubscriber1180%160%151544447711
FlowableRetryBiPredicate.RetryBiSubscriber1170%100%111138386611
BlockingFlowableLatest.LatestSubscriberIterator1150%200%171733337711
FlowableAmb.AmbInnerSubscriber1150%120%131334347711
FlowableMergeWithCompletable.MergeWithSubscriber1130%40%111131319911
FlowableAllSingle.AllSubscriber1130%120%131342427711
FlowableAnySingle.AnySubscriber1120%120%131341417711
FlowableRangeLong.RangeConditionalSubscription1120%220%141434343311
FlowableWithLatestFromMany1110%80%7733333311
FlowableRangeLong.RangeSubscription1100%200%131334343311
FlowableSingle.SingleElementSubscriber1090%160%141440406611
FlowableIntervalRange.IntervalRangeSubscriber1090%120%111130305511
FlowableSingleMaybe.SingleElementSubscriber1090%140%141439397711
FlowableOnErrorNext.OnErrorNextSubscriber1070%120%111136365511
FlowableWindowTimed.AbstractWindowSubscriber1070%80%121237378811
FlowableDoOnLifecycle.SubscriptionLambdaSubscriber1070%80%111144447711
FlowableElementAt.ElementAtSubscriber1060%140%131338386611
FlowableBufferTimed1060%60%5518182211
FlowableWindowTimed1050%40%5519193311
FlowableElementAtMaybe.ElementAtSubscriber1050%120%131336367711
FlowableRange.RangeConditionalSubscription1030%220%141434343311
FlowableReduceMaybe.ReduceSubscriber1030%120%131339397711
FlowableReduce.ReduceSubscriber1020%120%121238386611
FlowableReduceSeedSingle.ReduceSeedObserver1010%100%121235357711
FlowableRange.RangeSubscription1010%200%131334343311
FlowableScan.ScanSubscriber1010%100%121240407711
FlowableSkipUntil.SkipUntilMainSubscriber1000%40%101027278811
FlowableAmb990%120%8833332211
FlowableCollectSingle.CollectSubscriber970%100%121236367711
FlowableRepeat.RepeatSubscriber970%120%121234346611
FlowableOnBackpressureDrop.BackpressureDropSubscriber960%120%131338387711
FlowableRepeatUntil.RepeatSubscriber960%100%111137376611
FlowableZip930%80%6626262211
FlowableTakeWhile.TakeWhileSubscriber930%100%121239397711
FlowableMapNotification.MapNotificationSubscriber910%n/a4430304411
FlowableMap.MapConditionalSubscriber900%100%101029295511
FlowableScalarXMap900%80%7734343311
FlowableTakeUntilPredicate.InnerSubscriber900%100%121235357711
FlowableWindowBoundarySelector.WindowBoundaryMainSubscriber.WindowEndSubscriberIntercept900%120%151525259911
FlowableDelay.DelaySubscriber890%40%9922227711
FlowableAll.AllSubscriber880%100%111136366611
FlowableLastSingle.LastSubscriber880%80%111129297711
FlowableAny.AnySubscriber870%100%111135356611
FlowableOnBackpressureError.BackpressureErrorSubscriber860%120%131333337711
FlowableFilter.FilterConditionalSubscriber830%160%131327275511
FlowableTakeUntil.TakeUntilMainSubscriber830%n/a7722227711
FlowableUsing820%n/a2227272211
FlowableFilter.FilterSubscriber810%140%121230305511
FlowableRefCount.RefCountSubscriber810%80%111126267711
FlowableSkipWhile.SkipWhileSubscriber800%60%101030307711
FlowableInterval.IntervalSubscriber800%60%8819195511
FlowableInternalHelper790%n/a13131414131311
FlowableFromIterable.BaseRangeSubscription790%180%161627277711
FlowableCollect.CollectSubscriber790%80%101032326611
FlowableOnErrorComplete.OnErrorCompleteSubscriber770%40%9926267711
FlowableTimeInterval.TimeIntervalSubscriber770%20%8824247711
FlowableBufferBoundary.BufferCloseSubscriber760%80%111124247711
FlowableGroupBy750%20%3322222211
FlowableTimeout.TimeoutConsumer750%80%111124247711
FlowableCombineLatest.CombineLatestInnerSubscriber740%20%8822227711
FlowableReplay.ReplayPublisher730%60%5526262211
FlowableFromArray.BaseArraySubscription730%100%121221217711
FlowableReplay.InnerSubscription730%80%111121217711
FlowableConcatWithCompletable.ConcatWithSubscriber720%40%101027278811
FlowableRepeatWhen.WhenReceiver720%60%101024247711
FlowableFlattenIterable720%40%5526263311
FlowableLastMaybe.LastSubscriber720%60%101025257711
FlowableIntervalRange700%20%3319192211
FlowableRangeLong.BaseRangeSubscription700%100%121221217711
FlowableConcatMapScheduler690%30%4413132211
FlowableRange.BaseRangeSubscription680%100%121221217711
FlowableConcatWithMaybe.ConcatWithSubscriber680%20%8824247711
FlowableUnsubscribeOn.UnsubscribeSubscriber670%100%121224247711
FlowableTimeoutTimed670%20%3317172211
FlowableDebounce.DebounceSubscriber.DebounceInnerSubscriber670%80%9926265511
FlowableDetach.DetachSubscriber660%20%8826267711
FlowableToListSingle.ToListSubscriber660%40%9922227711
FlowableWindow650%40%4411112211
FlowableDelaySubscriptionOther.MainSubscriber640%20%9922228811
FlowableSkip.SkipSubscriber630%40%9922227711
FlowableBuffer630%40%4411112211
FlowableCountSingle.CountSubscriber620%40%9920207711
FlowableOnBackpressureReduceWith.BackpressureReduceWithSubscriber620%40%4419192211
BlockingFlowableNext.NextSubscriber610%100%111119196611
FlowableConcatMap610%50%6613133311
FlowableGroupJoin610%n/a2215152211
FlowableJoin610%n/a2215152211
FlowableSkipLast.SkipLastSubscriber610%40%9921217711
FlowableInterval600%20%3317172211
FlowableCreate600%50%6621212211
FlowableRetryWhen600%n/a2218182211
FlowableRepeatWhen600%n/a2218182211
FlowableScalarXMap.ScalarXMapFlowable590%40%4424242211
FlowableRepeatWhen.WhenSourceSubscriber590%20%6621215511
FlowableSampleTimed590%20%3312122211
FlowableReplay.MulticastFlowable580%n/a2220202211
FlowableFromIterable580%40%5524243311
FlowableConcatWithSingle.ConcatWithSubscriber580%n/a7721217711
BlockingFlowableMostRecent.MostRecentSubscriber.Iterator580%80%8812124411
FlowableDelaySubscriptionOther.MainSubscriber.OtherSubscriber570%80%9919195511
FlowableFromFuture570%60%5518182211
FlowableConcatMap.ConcatMapInner570%40%7720205511
FlowableDoAfterNext.DoAfterConditionalSubscriber560%40%7721215511
FlowableIgnoreElements.IgnoreElementsSubscriber560%20%14142222131311
FlowableTimeout560%20%3316162211
FlowableMap.MapSubscriber560%60%7718184411
FlowablePublishMulticast.OutputCanceller540%20%8821217711
FlowableToList.ToListSubscriber540%40%8820206611
FlowableSwitchIfEmpty.SwitchIfEmptySubscriber540%40%7719195511
FlowableLift540%20%3317172211
FlowableOnErrorReturn.OnErrorReturnSubscriber540%n/a4416164411
FlowableIgnoreElementsCompletable.IgnoreElementsSubscriber530%40%9919197711
FlowableGroupJoin.LeftRightEndSubscriber520%40%9917177711
FlowableZipIterable520%20%3321212211
FlowablePublishMulticast520%n/a2216162211
FlowableDoOnEach520%20%3310102211
FlowableDebounceTimed.DebounceEmitter520%40%8816166611
FlowableTakeLastOne.TakeLastOneSubscriber510%40%8820206611
FlowableTimer.TimerSubscriber490%60%8818185511
FlowableOnBackpressureReduce.BackpressureReduceSubscriber490%40%4417172211
FlowableTakeUntil.TakeUntilMainSubscriber.OtherSubscriber490%n/a5512125511
FlowableToListSingle480%n/a4415154411
FlowableCollectSingle480%n/a3314143311
FlowableObserveOn470%20%3310102211
FlowableFlatMap470%20%4411113311
FlowableWithLatestFromMany.WithLatestInnerSubscriber470%20%7716166611
FlowableSequenceEqualSingle470%n/a3311113311
FlowableDelay460%20%3312122211
FlowableBufferBoundary.BufferBoundarySubscriber.BufferOpenSubscriber460%20%8816167711
FlowableFromSupplier440%20%4416163311
FlowableGroupJoin.LeftRightSubscriber440%20%8815157711
FlowableDoAfterNext.DoAfterSubscriber440%60%7717174411
FlowableFromRunnable440%60%6619193311
FlowableFromAction440%60%6619193311
FlowableFromCallable440%20%4416163311
FlowableCount.CountSubscriber440%20%7716166611
FlowableSamplePublisher.SampleMainEmitLast430%80%7716163311
FlowablePublishMulticast.MulticastSubscription430%60%7713134411
FlowableCache.CacheSubscription430%40%5513133311
FlowablePublish.InnerSubscription430%60%7713134411
FlowableHide.HideSubscriber420%20%8817177711
FlowableSkipUntil.SkipUntilMainSubscriber.OtherSubscriber420%n/a5511115511
FlowableFlatMapCompletableCompletable420%n/a33993311
FlowableTakeLastTimed420%n/a2210102211
FlowableFromCompletable.FromCompletableObserver410%20%6616165511
FlowableGroupBy.GroupedUnicast400%n/a6613136611
FlowableSamplePublisher400%20%3310102211
FlowableDistinctUntilChanged400%20%3310102211
FlowableWindowBoundary.WindowBoundaryInnerSubscriber390%60%7718184411
FlowableSampleTimed.SampleTimedEmitLast390%60%6612123311
FlowableThrottleLatest380%n/a22992211
FlowableWithLatestFrom380%n/a2210102211
FlowableSkipLastTimed370%n/a22992211
FlowableRange370%20%33882211
FlowableRepeat370%20%33882211
FlowableOnBackpressureBuffer370%n/a22992211
FlowableFlatMapMaybe.FlatMapMaybeSubscriber.InnerObserver370%n/a7712127711
FlowableRangeLong370%20%33882211
FlowableDistinct370%n/a2212122211
FlowableReduceWithSingle370%n/a2213132211
FlowableElementAtSingle360%n/a33883311
FlowableScanSeed360%n/a2212122211
FlowableThrottleFirstTimed360%n/a22992211
FlowableCreate.MissingEmitter360%80%6612122211
FlowableDebounceTimed360%n/a22992211
FlowableGenerate360%n/a2213132211
FlowableCollect350%n/a2212122211
FlowableInternalHelper.BufferedTimedReplay350%n/a22992211
FlowableOnBackpressureLatest.BackpressureLatestSubscriber350%40%4413132211
FlowableSwitchMap350%20%33992211
FlowableSequenceEqual340%n/a2210102211
FlowableWindowSubscribeIntercept340%40%55883311
FlowableBufferTimed.BufferSkipBoundedSubscriber.RemoveFromBuffer340%n/a22882211
FlowableConcatMapEagerPublisher340%n/a22992211
FlowableRetryPredicate330%n/a22992211
FlowableAutoConnect330%20%3310102211
FlowableTimer330%n/a2210102211
FlowableFromObservable.SubscriberObserver330%n/a7715157711
FlowableCreate.NoOverflowBaseAsyncEmitter320%60%5512122211
FlowableConcatMapEager320%n/a22882211
FlowableBufferBoundary320%n/a22992211
FlowableReplay.ScheduledReplayBufferSupplier320%n/a22882211
FlowableWindowBoundary320%n/a2210102211
FlowableFlatMapSingle.FlatMapSingleSubscriber.InnerObserver320%n/a6610106611
FlowableSubscribeOn320%n/a22992211
FlowableMaterialize.MaterializeSubscriber320%20%6612125511
FlowableOnBackpressureBufferStrategy320%n/a22882211
FlowableWindowBoundarySelector.WindowBoundaryMainSubscriber.WindowStartSubscriber320%20%7714146611
FlowableToList320%n/a2211112211
FlowableMap310%20%33772211
FlowableReduceMaybe310%n/a44884411
FlowableDoAfterNext310%20%33772211
FlowableFilter310%20%33772211
FlowableDoFinally310%20%33772211
FlowableRefCount.RefConnection310%20%4411113311
FlowableFlatMapCompletableCompletable.FlatMapCompletableMainSubscriber.InnerObserver310%n/a6610106611
FlowableFlatMapCompletable.FlatMapCompletableMainSubscriber.InnerConsumer310%n/a6610106611
FlowableInternalHelper.TimedReplay300%n/a22882211
FlowableElementAtMaybe300%n/a33773311
FlowableFlatMapSinglePublisher290%n/a22882211
FlowableInternalHelper.FlatMapWithCombinerOuter290%n/a22662211
FlowableWithLatestFrom.FlowableWithLatestSubscriber290%20%6611115511
FlowableSingleSingle290%n/a33773311
FlowableFlatMapMaybePublisher290%n/a22882211
FlowableConcatMap.SimpleScalarSubscription290%40%5510103311
FlowableAllSingle280%n/a33773311
FlowableFromArray280%20%33772211
FlowableTimeoutTimed.FallbackSubscriber280%n/a5512125511
FlowableRetryBiPredicate280%n/a22882211
FlowableRepeatUntil280%n/a22882211
FlowableAnySingle280%n/a33773311
FlowableDoOnLifecycle270%n/a22772211
FlowableFlatMapCompletable270%n/a22772211
FlowableFlatMapSingle270%n/a22772211
FlowableElementAt270%n/a22772211
FlowableMapNotification270%n/a22772211
FlowableWindowBoundarySelector270%n/a22772211
FlowableFlatMapMaybe270%n/a22772211
FlowableInternalHelper.ItemDelayFunction260%n/a22552211
FlowableDefer260%n/a2211112211
BlockingFlowableMostRecent.MostRecentSubscriber260%n/a5510105511
FlowableSkipUntil250%n/a22882211
FlowableDelaySubscriptionOther250%n/a22882211
FlowableMergeWithMaybe250%n/a22882211
FlowableMergeWithSingle250%n/a22882211
FlowableMergeWithMaybe.MergeWithObserver.OtherObserver250%n/a5511115511
FlowableMergeWithCompletable250%n/a22882211
FlowableBufferExactBoundary250%n/a22662211
FlowableOnBackpressureDrop250%n/a44994411
FlowableTakeUntil250%n/a22882211
FlowableReduceSeedSingle240%n/a22772211
FlowableError240%n/a2210102211
FlowableSamplePublisher.SamplerSubscriber240%n/a5511115511
FlowableConcatArray240%n/a22882211
FlowableSingleMaybe230%n/a33663311
FlowableSwitchIfEmpty230%n/a22772211
BlockingFlowableMostRecent220%n/a22772211
FlowableTimeInterval220%n/a22662211
FlowableOnBackpressureReduceWith220%n/a22662211
FlowableOnErrorNext220%n/a22772211
FlowableSingle220%n/a22662211
FlowableIgnoreElementsCompletable210%n/a33663311
FlowableMergeWithSingle.MergeWithObserver.OtherObserver210%n/a44994411
FlowableCountSingle210%n/a33663311
BlockingFlowableIterable210%n/a22772211
FlowableMergeWithCompletable.MergeWithSubscriber.OtherObserver200%n/a44994411
FlowableInternalHelper.BufferedReplaySupplier200%n/a22662211
FlowableDelay.DelaySubscriber.OnError200%n/a22662211
FlowableDebounce200%n/a22552211
FlowableBufferExactBoundary.BufferBoundarySubscriber190%n/a44994411
FlowableRepeatWhen.RepeatWhenSubscriber190%n/a33773311
FlowableMapPublisher190%n/a22662211
FlowableWithLatestFromMany.SingletonArrayFunc190%n/a22222211
FlowableElementAtMaybePublisher190%n/a22662211
FlowableTakePublisher190%n/a22662211
FlowableLastSingle190%n/a22662211
FlowableInternalHelper.FlatMapIntoIterable180%n/a22442211
BlockingFlowableLatest180%n/a22662211
FlowableJust180%n/a33663311
FlowableConcatWithSingle170%n/a22552211
FlowableOnBackpressureLatest170%n/a22552211
FlowableDematerialize170%n/a22552211
FlowableScan170%n/a22552211
FlowableTakeLast170%n/a22552211
FlowableOnErrorReturn170%n/a22552211
FlowableReduce170%n/a22552211
FlowableSkipLast170%n/a22552211
FlowableConcatWithCompletable170%n/a22552211
FlowableOnBackpressureReduce170%n/a22552211
FlowableSkipWhile170%n/a22552211
FlowableCombineLatest.SingletonArrayFunc170%n/a22222211
FlowableAny170%n/a22552211
FlowableAll170%n/a22552211
FlowableUnsubscribeOn170%n/a22552211
FlowableTakeUntilPredicate170%n/a22552211
FlowableTakeWhile170%n/a22552211
FlowableOnErrorComplete170%n/a22552211
FlowableReplay.ReplayBufferSupplier170%n/a22552211
FlowableConcatWithMaybe170%n/a22552211
FlowableFromCompletable170%n/a33663311
FlowableRetryWhen.RetryWhenSubscriber170%n/a33773311
FlowableSkip170%n/a22552211
FlowableTake170%n/a22552211
BlockingFlowableNext170%n/a22552211
FlowableInternalHelper.FlatMapWithCombinerInner160%n/a22552211
FlowableDelay.DelaySubscriber.OnNext160%n/a22552211
FlowableTimeoutTimed.TimeoutTask150%n/a22662211
FlowableSampleTimed.SampleTimedNoLast150%n/a33663311
FlowableWindowTimed.WindowSkipSubscriber.WindowBoundaryRunnable150%n/a22662211
FlowableSubscribeOn.SubscribeOnSubscriber.Request150%n/a22662211
FlowableDelay.DelaySubscriber.OnComplete150%n/a22442211
FlowableReplay.SizeBoundReplayBuffer150%20%33662211
FlowableWindowTimed.WindowExactBoundedSubscriber.WindowBoundaryRunnable140%n/a22662211
FlowableReplay.MulticastFlowable.DisposableConsumer140%n/a22552211
FlowableFromObservable140%n/a22552211
FlowableLastMaybe140%n/a22552211
FlowableInternalHelper.RequestMax130%n/a22442211
FlowableInternalHelper.SimpleBiGenerator130%n/a22552211
FlowableCount120%n/a22442211
FlowableSamplePublisher.SampleMainNoLast120%n/a33663311
FlowableOnBackpressureError120%n/a22442211
FlowableTakeLastOne120%n/a22442211
FlowableHide120%n/a22442211
FlowableDetach120%n/a22442211
FlowableMaterialize120%n/a22442211
FlowableGroupBy.EvictionAction120%n/a22552211
AbstractFlowableWithUpstream120%n/a22442211
FlowableSerialized120%n/a22442211
FlowableInternalHelper.SimpleGenerator120%n/a22552211
FlowableIgnoreElements120%n/a22442211
FlowableFromPublisher110%n/a22552211
FlowableInternalHelper.SubscriberOnNext110%n/a22552211
FlowableInternalHelper.SubscriberOnError110%n/a22552211
FlowableUnsubscribeOn.UnsubscribeSubscriber.Cancellation110%n/a22332211
FlowableCreate.ErrorAsyncEmitter110%n/a22442211
FlowableInternalHelper.ReplaySupplier100%n/a22442211
FlowableInternalHelper.SubscriberOnComplete100%n/a22552211
FlowableEmpty100%n/a33443311
FlowableWindowTimed.WindowExactUnboundedSubscriber.WindowRunnable100%n/a22332211
FlowableReplay.Node90%n/a11441111
FlowableNever90%n/a22332211
FlowableReplay.DefaultUnboundedFactory0%n/a22222211
FlowableCache.Node0%n/a11331111
FlowableWindowBoundarySelector.WindowBoundaryMainSubscriber.WindowStartItem0%n/a11331111
FlowableCreate.DropAsyncEmitter0%n/a22332211