rx.internal.operators

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethodsMissedClasses
Total35,846 of 35,8460%3,475 of 3,4750%3,7083,70810,44910,4491,9681,968519519
OperatorMerge.MergeSubscriber1,1430%1860%114114381381212111
OnSubscribePublishMulticast5720%840%5757150150151511
OperatorSwitch.SwitchSubscriber5370%740%5353161161161611
OnSubscribeCombineLatest.LatestCoordinator5220%860%5454144144111111
OperatorReplay.ReplaySubscriber5140%680%4747148148131311
OperatorPublish.PublishSubscriber5130%780%5050140140111111
OperatorGroupBy.GroupBySubscriber5070%700%4848150150131311
OperatorGroupByEvicting.GroupBySubscriber4640%640%4444140140121211
OperatorWindowWithTime.ExactSubscriber4510%580%4141143143121211
OperatorWindowWithObservableFactory.SourceSubscriber4290%480%3636149149121211
OnSubscribeFlatMapSingle.FlatMapSingleSubscriber3920%700%42421221227711
OperatorWindowWithObservable.SourceSubscriber3900%480%3636137137121211
OnSubscribeFlattenIterable.FlattenIterableSubscriber3810%580%36361241247711
OnSubscribeConcatMap.ConcatMapSubscriber3720%620%4242118118111111
OperatorReplay.BoundedReplayBuffer3650%460%4040109109171711
OnSubscribeAmb3300%120%18188686121211
OperatorEagerConcatMap.EagerOuterSubscriber3300%460%30301131137711
OperatorWindowWithSize.WindowOverlap3300%460%313199998811
BackpressureUtils3280%600%41418888111111
OperatorGroupByEvicting.State3160%500%35359696101011
OperatorScan.InitialProducer3120%460%32321031039911
OperatorGroupBy.State3050%480%34349494101011
OperatorWindowWithTime.InexactSubscriber3040%280%232383839911
OperatorMapNotification.MapNotificationSubscriber2910%420%292983838811
CachedObservable.ReplayProducer2900%480%30301021026611
OperatorObserveOn.ObserveOnSubscriber2890%500%333392928811
OperatorWindowWithStartEndObservable.SourceSubscriber2660%220%191977778811
OperatorBufferWithTime.InexactSubscriber2660%280%212180807711
OperatorOnBackpressureLatest.LatestEmitter2460%380%29298080101011
OnSubscribeTimeoutSelectorWithFallback.TimeoutMainSubscriber2400%280%222265658811
OperatorZip.Zip2350%280%181859594411
OnSubscribeJoin.ResultSink.RightSubscriber2300%200%151551515511
OnSubscribeJoin.ResultSink.LeftSubscriber2210%200%151549495511
OnSubscribeRedo2200%80%18184343141411
OperatorBufferWithStartEndObservable.BufferingSubscriber2180%180%151569696611
CachedObservable.CacheState2120%160%171762629911
OnSubscribeTimeoutTimedWithFallback.TimeoutMainSubscriber1970%180%161650507711
OnSubscribeFlatMapCompletable.FlatMapCompletableSubscriber1950%240%191956567711
OperatorReplay.SizeAndTimeBoundReplayBuffer1890%240%181855556611
OperatorOnBackpressureBuffer.BufferSubscriber1830%300%26265555111111
OperatorReplay.InnerProducer1780%300%222249497711
OperatorBufferWithTime.ExactSubscriber1760%120%121255556611
OnSubscribeCreate.BufferEmitter1760%340%242463637711
OnSubscribeCreate.LatestEmitter1750%340%242463637711
CompletableOnSubscribeMerge.CompletableMergeSubscriber1740%280%202052526611
OperatorReplay1690%180%21213737121211
OperatorReplay.UnboundedReplayBuffer1680%260%181854545511
DeferredScalarSubscriber1670%320%252553539911
OperatorWithLatestFromMany.WithLatestMainSubscriber1650%160%171755559911
CompletableOnSubscribeMergeDelayErrorIterable1630%300%171759592211
OnSubscribeGroupJoin.ResultManager.LeftObserver1630%40%6636364411
OnSubscribeFromIterable.IterableProducer1610%320%202066664411
OnSubscribeFromArray.FromArrayProducer1590%300%191945454411
OperatorBufferWithSize.BufferOverlap1580%140%121237375511
OnSubscribeRange.RangeProducer1580%300%191946464411
OperatorPublish.InnerProducer1540%300%202042425511
OperatorBufferWithSingleObservable.BufferingSubscriber1530%100%101051515511
OnSubscribeGroupJoin.ResultManager1520%60%111143438811
OnSubscribeDetach.DetachSubscriber1520%180%161642427711
CompletableOnSubscribeMergeIterable1410%220%131353532211
OperatorMaterialize.ParentSubscriber1380%160%161650508811
OperatorDebounceWithTime.DebounceState1370%120%111146465511
CompletableOnSubscribeConcat.CompletableConcatSubscriber1370%220%181848487711
OperatorTakeLastTimed.TakeLastTimedSubscriber1370%80%111137377711
OnSubscribeGroupJoin.ResultManager.RightObserver1350%40%6631314411
OperatorMulticast1330%60%6631313311
BufferUntilSubscriber1320%160%161630308811
BlockingOperatorNext.NextIterator1320%200%151539395511
OnSubscribeUsing1280%60%6642423311
OperatorWindowWithSize.WindowSkip1260%140%131343436611
BlockingOperatorLatest.LatestObserverIterator1200%220%181832327711
OnSubscribeReduce.ReduceSubscriber1170%140%131338386611
OnSubscribeCombineLatest1170%100%8832323311
BlockingOperatorToIterator.SubscriberIterator1170%120%16163333101011
OnSubscribeOnAssembly1140%260%161635353311
OperatorWindowWithSize.WindowExact1130%100%111139396611
OnSubscribeSwitchIfEmpty.ParentSubscriber1120%140%131337376611
OperatorWithLatestFromMany1120%100%7728282211
SingleOnSubscribeUsing1120%60%6639393311
BlockingOperatorToFuture.new Future() {...}1030%100%121220207711
NotificationLite1000%220%22222626111111
OperatorBufferWithSize.BufferSkip990%100%101031315511
OperatorGroupByEvicting990%20%5528284411
OperatorOnErrorResumeNextViaFunction.new Subscriber() {...}970%80%9930305511
OperatorPublish920%120%111122225511
OperatorSingle.ParentSubscriber910%120%101026264411
OperatorAny.new Subscriber() {...}900%120%101025254411
OperatorZip900%n/a10103333101011
OnSubscribeDoOnEach.DoOnEachSubscriber900%60%7735354411
CompletableOnSubscribeConcatIterable.ConcatInnerSubscriber890%120%111137375511
SingleOperatorZip.new Single.OnSubscribe() {...}890%120%8819192211
OnSubscribeRefCount890%40%7721215511
CompletableOnSubscribeMergeArray880%120%8822222211
BufferUntilSubscriber.OnSubscribeAction870%100%7723232211
OperatorRetryWithPredicate.SourceSubscriber.1.new Subscriber() {...}870%100%101017175511
OperatorTake.new Subscriber() {...}860%140%121221215511
OperatorBufferWithSize850%80%6622222211
CompletableOnSubscribeMergeDelayErrorArray840%100%7720202211
OperatorGroupBy820%n/a5523235511
OperatorElementAt.new Subscriber() {...}800%60%8816165511
OperatorSkipLastTimed.new Subscriber() {...}790%40%7719195511
OperatorDistinctUntilChanged.new Subscriber() {...}780%40%6625254411
OnSubscribeRedo.2.new Subscriber() {...}780%100%111124246611
CompletableOnSubscribeMerge.CompletableMergeSubscriber.new CompletableSubscriber() {...}770%100%9922224411
SingleTimeout.TimeoutSingleSubscriber770%80%8823234411
SingleFromObservable.WrapSingleIntoSubscriber760%100%9925254411
OperatorOnBackpressureDrop.new Subscriber() {...}760%100%101023235511
OperatorOnBackpressureBuffer750%40%8823236611
OperatorMerge.InnerSubscriber750%40%9926267711
OperatorDebounceWithSelector.new Subscriber() {...}750%n/a5521215511
OperatorWindowWithSize740%40%4418182211
OnSubscribeAmb.AmbSubscriber740%120%121227276611
OperatorWindowWithSize.WindowOverlap.WindowOverlapProducer730%80%6615152211
OnSubscribeToMultimap.ToMultimapSubscriber730%40%5524243311
OnSubscribeCreate.BaseEmitter730%60%14142929111111
OnSubscribeToMultimap720%20%6625255511
OperatorWindowWithSize.WindowSkip.WindowSkipProducer720%80%6614142211
OnSubscribeFilter.FilterSubscriber720%60%8829295511
OperatorBufferWithSize.BufferSkip.BufferSkipProducer720%80%6614142211
OperatorTakeLast.TakeLastSubscriber710%40%8819196611
SingleFromEmitter.SingleEmitterImpl710%80%111123237711
OperatorTakeWhile.new Subscriber() {...}710%60%7720204411
OnSubscribeRefCount.new Subscriber() {...}710%40%7718185511
CompletableOnSubscribeConcatArray.ConcatInnerSubscriber700%100%101025255511
OperatorAll.new Subscriber() {...}700%80%8822224411
OperatorBufferWithSize.BufferExact690%60%8823235511
OperatorBufferWithTime690%20%3321212211
OperatorMapPair.MapPairSubscriber690%40%7726265511
SingleDelay.ObserveOnSingleSubscriber680%20%5521214411
OperatorDematerialize.new Subscriber() {...}680%100%101018184411
OperatorDebounceWithTime.new Subscriber() {...}680%n/a5514145511
OperatorSkipWhile.new Subscriber() {...}680%40%6618184411
OnSubscribeToObservableFuture.ToObservableFuture670%60%6621213311
OperatorMerge660%60%7718184411
OperatorToObservableSortedList.new Subscriber() {...}660%40%7720205511
SingleOperatorZip.1.new SingleSubscriber() {...}650%40%5515153311
OperatorZipIterable.new Subscriber() {...}650%80%8821214411
OnSubscribeFlatMapSingle650%40%4416162211
OnSubscribeSingle.new Subscriber() {...}640%60%8818185511
OperatorSampleWithTime.SamplerSubscriber640%20%9926268811
OnSubscribeCombineLatest.CombinerSubscriber640%60%8823235511
CompletableOnSubscribeMerge640%60%6617173311
OperatorTakeUntilPredicate.ParentSubscriber640%60%8824245511
CompletableFromEmitter.FromEmitter640%60%101021217711
OperatorWindowWithTime630%20%4419193311
OperatorScan620%20%6617175511
CompletableOnSubscribeTimeout610%n/a2215152211
OperatorBufferWithSingleObservable610%n/a3319193311
SingleOnSubscribeUsing.new SingleSubscriber() {...}610%40%5518183311
OperatorToObservableList.new Subscriber() {...}610%40%7719195511
OnSubscribeConcatMap600%40%4416162211
OnSubscribeFlatMapCompletable600%40%4415152211
SingleOperatorOnErrorResumeNext600%60%7716164411
BlockingOperatorNext.NextObserver590%100%111117176611
OnSubscribeFlattenIterable590%20%4414143311
SingleDoOnEvent.SingleDoOnEventSubscriber580%n/a3320203311
OperatorCast.CastSubscriber580%40%7725255511
OperatorBufferWithSize.BufferOverlap.BufferOverlapProducer580%80%6612122211
OnSubscribeMap.MapSubscriber580%40%7725255511
BlockingOperatorMostRecent.MostRecentObserver.new Iterator() {...}580%80%8812124411
OperatorThrottleFirst.new Subscriber() {...}580%60%8813135511
OperatorSubscribeOn.SubscribeOnSubscriber580%n/a6621216611
OperatorSkipLast.new Subscriber() {...}580%40%6614144411
OperatorTakeLastTimed580%20%4416163311
OperatorWithLatestFrom570%n/a3314143311
OnSubscribeJoin.ResultSink570%n/a3315153311
OperatorEagerConcatMap.EagerInnerSubscriber570%20%6620205511
OperatorReplay.new Observable.OnSubscribe() {...}570%40%4415152211
OperatorTake.1.new Producer() {...}570%80%6612122211
OnSubscribePublishMulticast.PublishProducer570%60%7715154411
OperatorSampleWithObservable570%n/a3314143311
OperatorOnErrorResumeNextViaFunction570%n/a5513135511
OnSubscribeCreate560%50%6618182211
OnSubscribeToMap560%20%5519194411
OperatorWithLatestFrom.new Subscriber() {...}550%20%5516164411
OperatorScan.new Subscriber() {...}550%n/a5517175511
OnSubscribeFlatMapCompletable.FlatMapCompletableSubscriber.InnerSubscriber550%100%111115156611
CompletableOnSubscribeMergeArray.new CompletableSubscriber() {...}540%60%7712124411
OperatorScan.new Subscriber() {...}540%20%5517174411
OperatorObserveOn540%60%7715154411
SingleObserveOn.ObserveOnSingleSubscriber540%20%5519194411
OperatorDelay.new Subscriber() {...}540%n/a44774411
CompletableOnSubscribeMergeIterable.new CompletableSubscriber() {...}540%60%7712124411
OnSubscribeRedo.3.new Subscriber() {...}540%80%9913135511
CompletableOnSubscribeMergeDelayErrorIterable.new CompletableSubscriber() {...}530%40%7713135511
OnSubscribeGroupJoin.ResultManager.LeftDurationObserver530%40%6617174411
CompletableOnSubscribeMergeDelayErrorArray.new CompletableSubscriber() {...}530%40%7713135511
OperatorPublish.new Observable.OnSubscribe() {...}520%80%6615152211
OperatorSampleWithObservable.new Subscriber() {...}520%20%5513134411
OperatorMulticast.new Action0() {...}510%40%4412122211
OnSubscribeToMap.ToMapSubscriber510%20%4419193311
OnSubscribeTimeoutSelectorWithFallback.TimeoutMainSubscriber.TimeoutConsumer510%60%7717174411
SingleTakeUntilCompletable.TakeUntilSourceSubscriber510%40%7717175511
OnSubscribeRedo.4.new Subscriber() {...}510%40%7712125511
CompletableOnSubscribeTimeout.new CompletableSubscriber() {...}500%40%6612124411
SingleTakeUntilSingle.TakeUntilSourceSubscriber500%40%5515153311
SingleTakeUntilObservable.TakeUntilSourceSubscriber500%40%5515153311
OperatorDistinct.new Subscriber() {...}500%20%5513134411
CachedObservable490%40%7711115511
SingleOnSubscribeDelaySubscriptionOther.new Subscriber() {...}490%40%6615154411
OnSubscribeTimeoutTimedWithFallback490%n/a2213132211
OnSubscribeAmb.new Producer() {...}490%80%6611112211
CompletableFlatMapSingleToCompletable.SourceSubscriber490%20%6621215511
OperatorElementAt490%20%5514144411
SingleLiftObservableOperator490%n/a3317173311
OnSubscribeRefCount.new Action0() {...}490%60%5510102211
OnSubscribeGroupJoin.ResultManager.RightDurationObserver480%20%5515154411
OperatorPublish.new Observable.OnSubscribe() {...}480%n/a22882211
OnSubscribeDelaySubscriptionOther.new Subscriber() {...}480%40%6615154411
OperatorSkip.new Subscriber() {...}480%20%6612125511
SingleTimeout480%n/a2214142211
OperatorDelayWithSelector.new Subscriber() {...}470%n/a4410104411
SingleFromFuture470%20%3317172211
OnSubscribeRedo.new Producer() {...}470%40%44772211
OperatorToObservableSortedList470%n/a4414144411
OperatorZip.ZipSubscriber460%60%7715154411
OperatorTimeInterval.new Subscriber() {...}450%n/a4410104411
SingleOnSubscribeMap.MapSubscriber450%20%4419193311
CompletableOnSubscribeTimeout.new Action0() {...}440%40%44772211
OnSubscribeSkipTimed440%n/a2213132211
OperatorZip.Zip.InnerSubscriber440%n/a6617176611
OperatorSampleWithTime440%n/a2212122211
CompletableOnSubscribeConcatIterable440%20%3317172211
OnSubscribeFlatMapSingle.FlatMapSingleSubscriber.Requested440%40%7713135511
OnSubscribeFlattenIterable.OnSubscribeScalarFlattenIterable430%20%3316162211
OperatorWindowWithTime.State430%n/a6610106611
OnSubscribeFromIterable420%60%5516162211
OnSubscribeTimeoutSelectorWithFallback420%n/a2212122211
OperatorWindowWithStartEndObservable420%n/a2212122211
OperatorTakeUntil420%n/a2211112211
OnSubscribeCreate.ErrorEmitter420%60%8819195511
OnSubscribeRedo.new Action0() {...}420%20%33772211
OperatorDistinctUntilChanged410%60%8811115511
OperatorSequenceEqual.new Func2() {...}410%120%88882211
OperatorMerge.MergeProducer400%60%6612123311
SingleDelay400%n/a2212122211
OperatorDebounceWithTime400%n/a2211112211
OnSubscribeSwitchIfEmpty400%n/a2212122211
OperatorRetryWithPredicate.SourceSubscriber390%n/a4413134411
OperatorSkipUntil.new Subscriber() {...}390%20%5511114411
OperatorReplay.ReplaySubscriber.new Action0() {...}390%40%44992211
OnSubscribeAmb.Selection390%60%6612123311
OperatorDoAfterTerminate.new Subscriber() {...}390%n/a5515155511
OperatorSampleWithObservable.new Subscriber() {...}390%n/a4410104411
BlockingOperatorToFuture380%n/a22772211
OperatorMulticast.new Observable.OnSubscribe() {...}380%20%33772211
OperatorTake380%40%4411112211
OperatorSkipUntil380%n/a22992211
OperatorBufferWithSize.BufferExact.new Producer() {...}380%40%44772211
OperatorReplay.new Observable.OnSubscribe() {...}380%n/a2210102211
OnSubscribeTimerPeriodically380%n/a2210102211
SingleOnSubscribeDelaySubscriptionOther380%n/a2211112211
OperatorWindowWithSize.WindowExact.new Producer() {...}380%40%44772211
OperatorWithLatestFrom.new Subscriber() {...}370%20%5510104411
OperatorTakeTimed370%n/a2210102211
OperatorBufferWithStartEndObservable370%n/a2210102211
OperatorWindowWithStartEndObservable.SourceSubscriber.new Subscriber() {...}370%20%5511114411
OperatorSubscribeOn370%n/a2211112211
OperatorPublish.2.new Subscriber() {...}370%n/a5511115511
OnSubscribeLift370%n/a2216162211
OperatorWindowWithObservable360%n/a3311113311
OnSubscribeConcatMap.ConcatMapInnerSubscriber360%n/a5512125511
OperatorRetryWithPredicate360%n/a2210102211
OnSubscribeAutoConnect360%40%4411112211
OperatorGroupBy.GroupedUnicast360%n/a5511115511
OperatorGroupByEvicting.GroupedUnicast360%n/a5511115511
OperatorBufferWithStartEndObservable.BufferingSubscriber.new Subscriber() {...}360%n/a44994411
OnSubscribeDelaySubscriptionOther350%n/a2211112211
OperatorWindowWithObservableFactory.BoundarySubscriber350%40%7715155511
OperatorZipIterable350%20%3313132211
OnSubscribeUsing.DisposeAction350%20%5513134411
OnSubscribeDelaySubscription350%n/a2210102211
OperatorMapNotification350%n/a22992211
CachedObservable.CachedSubscribe350%40%4410102211
OperatorSingle350%n/a5512125511
OnSubscribeRedo.new Action0() {...}350%n/a22332211
OperatorSwitch.InnerSubscriber350%n/a5512125511
OnSubscribeCollect350%n/a2213132211
OnSubscribeRedo.RedoFinite.new Func1() {...}350%40%44772211
OperatorEagerConcatMap.EagerOuterProducer340%40%44992211
OperatorSubscribeOn.SubscribeOnSubscriber.new Producer() {...}340%40%44552211
OnSubscribeRefCount.new Action1() {...}340%n/a22662211
SingleDoAfterTerminate.SingleDoAfterTerminateSubscriber330%n/a4416164411
OnSubscribeGroupJoin330%n/a2211112211
OperatorDebounceWithSelector.1.new Subscriber() {...}330%n/a44884411
SingleOnErrorReturn.OnErrorReturnsSingleSubscriber330%n/a3314143311
OnSubscribeCollect.CollectSubscriber330%20%3314142211
OperatorSequenceEqual330%n/a44884411
OnSubscribeJoin.ResultSink.RightSubscriber.RightDurationSubscriber330%20%5512124411
OnSubscribeJoin.ResultSink.LeftSubscriber.LeftDurationSubscriber330%20%5512124411
OperatorRetryWithPredicate.SourceSubscriber.new Action0() {...}330%n/a22772211
OnSubscribeTimerPeriodically.new Action0() {...}330%n/a22772211
OnSubscribeGroupJoin.WindowObservableFunc.WindowSubscriber330%n/a4413134411
OperatorTakeLast320%20%33992211
OperatorSwitch.SwitchSubscriber.new Producer() {...}320%40%44662211
OnSubscribeSwitchIfEmpty.AlternateSubscriber320%n/a5513135511
OnSubscribeReduceSeed.ReduceSeedSubscriber320%n/a2212122211
OnSubscribeTimerOnce320%n/a22992211
OnSubscribeReduce320%n/a22992211
OperatorTimestamp.new Subscriber() {...}310%n/a44774411
BlockingOperatorToFuture.new Subscriber() {...}310%n/a44884411
SingleOperatorOnErrorResumeNext.new SingleSubscriber() {...}310%n/a33883311
OperatorTakeUntil.new Subscriber() {...}310%n/a44994411
OnSubscribeSkipTimed.SkipTimedSubscriber310%20%6614145511
OperatorOnBackpressureDrop310%n/a44994411
CompletableOnSubscribeTimeout.1.new CompletableSubscriber() {...}310%n/a44994411
OperatorDelayWithSelector310%n/a22882211
OnSubscribeOnAssembly.OnAssemblySubscriber310%n/a4411114411
OnSubscribeOnAssemblyCompletable.OnAssemblyCompletableSubscriber300%n/a4411114411
OnSubscribeConcatMap.ConcatMapInnerScalarProducer300%40%4410102211
OnSubscribeRedo.RetryWithPredicate.new Func2() {...}300%20%33552211
OnSubscribeJoin300%n/a2210102211
OperatorSkipUntil.new Subscriber() {...}300%n/a44994411
SingleDoOnEvent300%n/a22992211
SingleObserveOn300%n/a2210102211
OperatorAny290%n/a22992211
OnSubscribeGroupJoin.WindowObservableFunc290%n/a22992211
OperatorOnErrorResumeNextViaFunction.4.new Subscriber() {...}290%n/a55995511
OnSubscribeTakeLastOne.TakeLastOneSubscriber290%20%5511114411
OperatorElementAt.InnerProducer290%60%55882211
OperatorOnBackpressureLatest290%n/a33993311
OnSubscribeCreate.NoneEmitter290%60%55992211
OnSubscribeOnAssemblySingle.OnAssemblySingleSubscriber290%n/a3310103311
OperatorWithLatestFromMany.WithLatestOtherSubscriber290%n/a4410104411
OperatorMapPair280%n/a33883311
OperatorTakeTimed.TakeSubscriber280%n/a5513135511
OnSubscribeDetach280%n/a22992211
OperatorUnsubscribeOn.new Subscriber() {...}280%n/a55995511
OperatorDelay.1.new Action0() {...}280%20%33662211
OnSubscribeTimeoutTimedWithFallback.FallbackSubscriber280%n/a5512125511
OnSubscribeDelaySubscriptionWithSelector280%n/a22992211
SingleTakeUntilObservable280%n/a22992211
SingleTakeUntilSingle280%n/a22992211
OperatorOnBackpressureLatest.LatestSubscriber280%n/a6613136611
OperatorSkip270%20%33662211
OperatorWindowWithStartEndObservable.new Subscriber() {...}270%n/a55995511
OperatorEagerConcatMap270%n/a22882211
OperatorDelay270%n/a22882211
DeferredScalarSubscriberSafe270%40%5512123311
OperatorDoOnRequest.ParentSubscriber270%n/a5512125511
CompletableFromEmitter260%n/a2211112211
OperatorAll260%n/a22882211
OperatorSwitch260%20%4410103311
SingleFromEmitter260%n/a2211112211
OnSubscribeSingle260%n/a33883311
SingleTakeUntilCompletable260%n/a22992211
OperatorDebounceWithSelector260%n/a22772211
BlockingOperatorMostRecent.MostRecentObserver260%n/a5510105511
OperatorTakeWhile260%n/a33883311
OnSubscribeCreate.NoOverflowBaseEmitter260%40%44992211
CompletableFlatMapSingleToCompletable250%n/a22882211
OperatorToObservableList250%n/a33883311
OperatorWindowWithObservableFactory250%n/a33883311
OnSubscribeMap250%n/a22882211
SingleOnSubscribeMap250%n/a22882211
SingleDoAfterTerminate250%n/a22882211
OnSubscribeFromCallable250%n/a2210102211
OperatorTakeUntil.new Subscriber() {...}250%n/a55995511
OnSubscribeTimerOnce.new Action0() {...}250%n/a22882211
SingleDoOnSubscribe250%n/a2212122211
OnSubscribePublishMulticast.ParentSubscriber250%n/a5511115511
CompletableOnSubscribeConcat250%n/a22882211
OnSubscribeFilter250%n/a22882211
OperatorMulticast.new Subscriber() {...}240%n/a44774411
OnSubscribeReduceSeed240%n/a22772211
OperatorSerialize.new Subscriber() {...}240%n/a44774411
OperatorTakeUntilPredicate240%n/a22772211
SingleOnErrorReturn240%n/a22882211
OperatorReplay.3.new Subscriber() {...}240%n/a44774411
OnSubscribeDelaySubscriptionWithSelector.new Subscriber() {...}240%n/a44664411
OnSubscribeDefer230%n/a2210102211
OperatorBufferWithStartEndObservable.new Subscriber() {...}230%n/a44774411
OnSubscribeAmb.new Action0() {...}230%20%33552211
OperatorDoOnRequest230%n/a22772211
OperatorUnsubscribeOn.new Action0() {...}230%n/a22442211
OperatorWindowWithObservable.BoundarySubscriber230%n/a5511115511
BlockingOperatorMostRecent.new Iterable() {...}230%n/a22442211
SingleFromCallable220%n/a2211112211
OperatorUnsubscribeOn220%n/a22662211
OnSubscribeDelaySubscription.new Action0() {...}220%20%33442211
EmptyObservableHolder220%n/a33663311
OperatorReplay.new Func0() {...}220%n/a22222211
OperatorDebounceWithTime.1.new Action0() {...}220%n/a22332211
OperatorBufferWithSingleObservable.new Subscriber() {...}220%n/a44774411
OperatorMaterialize220%n/a33773311
CompletableOnSubscribeConcat.CompletableConcatSubscriber.ConcatInnerSubscriber210%n/a44774411
SingleTakeUntilObservable.TakeUntilSourceSubscriber.OtherSubscriber210%n/a44774411
OperatorPublish.PublishSubscriber.new Action0() {...}210%n/a22442211
SingleLiftObservableOperator.WrapSubscriberIntoSingle210%n/a33773311
OnSubscribeRange200%n/a22662211
OperatorObserveOn.ObserveOnSubscriber.new Producer() {...}200%20%33552211
OperatorDelay.1.new Action0() {...}200%20%33442211
OperatorDoOnRequest.new Producer() {...}200%n/a22442211
OperatorSkipLast200%20%33662211
NeverObservableHolder200%n/a33553311
CompletableOnSubscribeConcatArray200%n/a22772211
CachedObservable.CacheState.new Subscriber() {...}200%n/a44774411
OnSubscribeDoOnEach200%n/a22662211
OperatorDoAfterTerminate200%20%33662211
SingleDoOnUnsubscribe190%n/a22772211
OnSubscribeOnAssemblySingle190%n/a22662211
SingleOnSubscribeDelaySubscriptionOther.new SingleSubscriber() {...}190%n/a33553311
OperatorIgnoreElements.new Subscriber() {...}190%n/a44664411
OperatorEagerConcatMap.EagerOuterSubscriber.new Action0() {...}190%20%33552211
OperatorDelay.1.new Action0() {...}190%20%33552211
SingleFromObservable190%n/a22772211
SingleToObservable190%n/a22772211
OnSubscribeDetach.DetachProducer190%n/a44884411
OnSubscribeOnAssemblyCompletable190%n/a22662211
OnSubscribeToObservableFuture190%n/a33443311
OperatorObserveOn.new Observable.Operator() {...}190%n/a22442211
OperatorMaterialize.new Producer() {...}180%20%33442211
OperatorSkipWhile180%n/a33553311
OperatorThrottleFirst180%n/a22552211
OperatorCast180%n/a22662211
BlockingOperatorLatest.new Iterable() {...}180%n/a22442211
OnSubscribeFlatMapSingle.FlatMapSingleSubscriber.InnerSubscriber180%n/a33553311
OperatorWindowWithTime.ExactSubscriber.new Action0() {...}180%20%33442211
BufferUntilSubscriber.State180%n/a22442211
BlockingOperatorToIterator180%n/a22552211
OperatorSkipLastTimed180%n/a22552211
SingleTakeUntilSingle.TakeUntilSourceSubscriber.OtherSubscriber180%n/a33553311
BlockingOperatorNext.new Iterable() {...}170%n/a22332211
OperatorUnsubscribeOn.2.new Action0() {...}170%n/a22442211
OperatorReplay.new Observable.OnSubscribe() {...}170%n/a22332211
OperatorToObservableSortedList.new Comparator() {...}170%n/a22222211
OperatorSubscribeOn.SubscribeOnSubscriber.1.new Action0() {...}160%n/a22332211
OperatorIgnoreElements160%n/a33663311
OperatorMapPair.OuterInnerMapper160%n/a22552211
NotificationLite.OnErrorSentinel160%n/a22442211
OnSubscribeRedo.RetryWithPredicate160%n/a22442211
SingleTimeout.TimeoutSingleSubscriber.OtherSubscriber160%n/a33773311
OnSubscribeDetach.TerminatedProducer150%n/a22332211
OnSubscribeFromArray150%n/a22552211
OperatorBufferWithTime.InexactSubscriber.new Action0() {...}150%n/a22332211
OnSubscribeTimeoutTimedWithFallback.TimeoutMainSubscriber.TimeoutTask150%n/a22552211
OperatorSerialize150%n/a33443311
OperatorDistinct150%n/a33553311
OperatorOnErrorResumeNextViaFunction.new Func1() {...}150%20%33442211
OperatorWindowWithTime.InexactSubscriber.new Action0() {...}150%n/a22332211
OperatorOnBackpressureDrop.new Producer() {...}150%n/a22332211
OnSubscribeRedo.RedoFinite140%n/a22552211
SingleOperatorZip140%n/a22332211
OperatorDoOnUnsubscribe140%n/a22552211
OperatorReplay.SizeBoundReplayBuffer140%20%33662211
OnSubscribeTakeLastOne140%n/a22552211
OperatorTakeLast.new Producer() {...}140%n/a22332211
OperatorTakeLastTimed.new Producer() {...}140%n/a22332211
OperatorMapNotification.new Producer() {...}140%n/a22332211
OnSubscribeFlattenIterable.new Producer() {...}140%n/a22332211
OperatorZip.ZipProducer140%n/a22662211
OperatorTakeUntilPredicate.new Producer() {...}140%n/a22332211
OnSubscribeConcatMap.new Producer() {...}140%n/a22332211
OperatorReplay.2.new Action1() {...}140%n/a22332211
OnSubscribeReduce.new Producer() {...}140%n/a22332211
OperatorGroupByEvicting.new Action0() {...}130%n/a22332211
BlockingOperatorMostRecent130%n/a22332211
OnSubscribeToObservableFuture.ToObservableFuture.new Action0() {...}130%n/a22332211
OperatorTimeInterval130%n/a22442211
OperatorTimestamp130%n/a22442211
OperatorGroupBy.new Action0() {...}130%n/a22332211
OperatorMapPair.new Func1() {...}130%n/a22222211
OperatorToObservableSortedList.DefaultComparableFunction130%n/a22442211
OnSubscribeRedo.new Observable.Operator() {...}130%n/a22222211
OperatorDoOnSubscribe120%n/a22552211
OperatorGroupByEvicting.EvictionAction120%n/a22552211
BufferUntilSubscriber.OnSubscribeAction.new Action0() {...}120%n/a22332211
BlockingOperatorLatest120%n/a22332211
OperatorReplay.new ConnectableObservable() {...}120%n/a22332211
OperatorReplay.new Func0() {...}120%n/a22222211
OperatorDelayWithSelector.1.new Func1() {...}120%n/a22222211
OperatorSkipWhile.new Func2() {...}120%n/a22222211
OperatorBufferWithSingleObservable.new Func0() {...}120%n/a22222211
OperatorDematerialize120%n/a33443311
OperatorWindowWithTime.CountedSerializedSubject120%n/a11441111
OperatorGroupBy.GroupBySubscriber.EvictionAction120%n/a22552211
OperatorOnErrorResumeNextViaFunction.new Func1() {...}120%n/a22222211
OperatorTakeWhile.new Func2() {...}120%n/a22222211
BlockingOperatorNext120%n/a22332211
OperatorWindowWithStartEndObservable.SerializedSubject120%n/a11441111
OnSubscribeToMultimap.DefaultMultimapCollectionFactory110%n/a33333311
SingleOperatorCast110%n/a22442211
OperatorGroupBy.GroupByProducer110%n/a22552211
OnSubscribeThrow110%n/a22552211
OperatorGroupByEvicting.GroupByProducer110%n/a22552211
DeferredScalarSubscriber.InnerProducer110%n/a22552211
OperatorMerge.HolderDelayErrors100%n/a22222211
OperatorMerge.HolderNoDelay100%n/a22222211
OperatorSwitch.SwitchSubscriber.new Action0() {...}100%n/a22332211
OperatorBufferWithTime.InexactSubscriber.new Action0() {...}100%n/a22332211
OperatorWindowWithTime.ExactSubscriber.new Action0() {...}100%n/a22332211
OperatorBufferWithTime.ExactSubscriber.new Action0() {...}100%n/a22332211
OnSubscribeRedo.new Func1() {...}100%n/a22222211
OperatorWindowWithTime.InexactSubscriber.new Action0() {...}100%n/a22332211
OperatorSwitch.Holder0%n/a22222211
OperatorScan.new Func0() {...}0%n/a22222211
SingleOperatorOnErrorResumeNext.new Func1() {...}0%n/a22222211
OperatorSwitch.HolderDelayError0%n/a22222211
OperatorDistinctUntilChanged.Holder0%n/a22222211
OperatorDistinct.Holder0%n/a22222211
OperatorOnErrorResumeNextViaFunction.new Func1() {...}0%n/a22222211
OnSubscribeRedo.1.new Func1() {...}0%n/a22222211
OperatorReplay.Node0%n/a11441111
OperatorToObservableList.Holder0%n/a22222211
OperatorIgnoreElements.Holder0%n/a22222211
OperatorOnBackpressureLatest.Holder0%n/a22222211
OperatorMaterialize.Holder0%n/a22222211
OperatorOnBackpressureBuffer.Holder0%n/a22222211
OperatorReplay.new Func0() {...}0%n/a22222211
OperatorAsObservable.Holder0%n/a22222211
OperatorSingle.Holder0%n/a22222211
OperatorSerialize.Holder0%n/a22222211
OperatorOnBackpressureDrop.Holder0%n/a22222211
OperatorDematerialize.Holder0%n/a22222211
OperatorAsObservable0%n/a33443311
BufferUntilSubscriber.new Observer() {...}0%n/a44444411
OnSubscribeCreate.DropEmitter0%n/a22332211
NotificationLite.new Serializable() {...}0%n/a22222211
NotificationLite.new Serializable() {...}0%n/a22222211
Created with JaCoCo 0.8.7.202105040129