InputWithIncrementingInteger.java 文件源码

@Setup
public void setup(final Blackhole bh) {
    this.bh = bh;
    final int size = getSize();
    observable = Flowable.range(0, size);

    firehose = Flowable.unsafeCreate(new IncrementingPublisher(size));
    iterable = new IncrementingIterable(size);

}