https://github.com/Netflix/concurrency-limits: concurrency-limits-core
  • Netflix Open Source Development 
package com.netflix.concurrency.limits.limit.measurement;

import java.util.function.Function;

public class SingleMeasurement implements Measurement {
    private Number value = null;

    @Override
    public Number add(Number sample) {
        return value = sample;
    }

    @Override
    public Number get() {
        return value;
    }

    @Override
    public void reset() {
        value = null;
    }

    @Override
    public void update(Function<Number, Number> operation) {
        value = operation.apply(value);
    }
}