Package io.wcm.caravan.commons.metrics.rx

Class HitsAndMissesCountingMetricsOperator<R>

  • Type Parameters:
    R - Items type
    All Implemented Interfaces:
    rx.functions.Func1<rx.Subscriber<? super R>,​rx.Subscriber<? super R>>, rx.functions.Function, rx.Observable.Operator<R,​R>
    @ProviderType
public final class HitsAndMissesCountingMetricsOperator<R>
extends Object
implements rx.Observable.Operator<R,​R>
    Operator counting hits and misses. If no element passes the operator, the missesCounter gets increased. For every passed element the hitsCounter gets increased.

    • Constructor Detail

      • HitsAndMissesCountingMetricsOperator

        public HitsAndMissesCountingMetricsOperator​(com.codahale.metrics.Counter hitsCounter,
                                            com.codahale.metrics.Counter missesCounter)
        Parameters:
        hitsCounter - Counter for hits
        missesCounter - Counter for misses

    • Method Detail

      • call

        public rx.Subscriber<? super R> call​(rx.Subscriber<? super R> subscriber)
        Specified by:
        call in interface rx.functions.Func1<rx.Subscriber<? super R>,​rx.Subscriber<? super R>>