Class OperatorEffectiveSpeedChecker

  • All Implemented Interfaces:
    rx.functions.Func1<rx.Subscriber<? super EffectiveSpeedCheck>,​rx.Subscriber<? super Fix>>, rx.functions.Function, rx.Observable.Operator<EffectiveSpeedCheck,​Fix>

    public class OperatorEffectiveSpeedChecker
    extends java.lang.Object
    implements rx.Observable.Operator<EffectiveSpeedCheck,​Fix>
    Given a sequence of fixes the first fix is consider to be the first fix that passes an effective speed check with its following fix. Having established the first fix then following fixes are discarded from the sequence that fail the effective speed check with the last confirmed fix.
    • Constructor Detail

      • OperatorEffectiveSpeedChecker

        public OperatorEffectiveSpeedChecker​(SegmentOptions options)
    • Method Detail

      • call

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