- 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 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.