Class TimerMetricsOperator<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 TimerMetricsOperator<R>
    extends Object
    implements rx.Observable.Operator<R,​R>
    Operator measuring the time an operation needs from executing the Func1.call(Object) to Observer.onCompleted() or Observer.onError(Throwable) method.
    • Constructor Detail

      • TimerMetricsOperator

        public TimerMetricsOperator​(com.codahale.metrics.Timer timer)
        Parameters:
        timer - Stop watch
    • 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>>