Taking up to n results with time based eviction

blub.java

package io.beekeeper.sample;

import java.util.concurrent.TimeUnit;

import com.codahale.metrics.health.HealthCheck.Result;

import io.reactivex.Observable;
import io.reactivex.schedulers.Schedulers;
import io.reactivex.subjects.ReplaySubject;
import io.reactivex.subjects.Subject;

class Blub {
    private final Subject<Result> lastResults = ReplaySubject.createWithTime(5, TimeUnit.MINUTES,
            Schedulers.computation());

    public Observable<Result> lastResults(int n) {
        return lastResults.takeLast(n);
    }

    public Observable<Result> lastFailures(int n) {
        return lastResults
            .filter(result -> !result.isHealthy())
            .takeLast(n);
    }
}