Class PerfObserver

src/jmh/java/io/reactivex/rxjava3/core/PerfObserver.java:22–50

import io.reactivex.rxjava3.disposables.Disposable;

public final class PerfObserver implements Observer<Object> {
    final CountDownLatch cdl;
    final Blackhole bh;
    public PerfObserver(Blackhole bh) {
        this.bh = bh;
        this.cdl = new CountDownLatch(1);
    }

    @Override
    public void onSubscribe(Disposable d) {

    }

    @Override
    public void onNext(Object value) {
        bh.consume(value);
    }

    @Override
    public void onError(Throwable e) {
        e.printStackTrace();
        cdl.countDown();
    }

    @Override
    public void onComplete() {
        cdl.countDown();
    }
}