These are chat archives for ReactiveX/RxJava
RxJava – Reactive Extensions for the JVM – a library for composing asynchronous and event-based programs using observable sequences for the Java VM.
I think this might work, but it is pretty weird… maybe you can rethink whatever you are trying to do in a more… reactive… way
Flowable<Long> buffer$ = Flowable.concatArrayEager( // maxConcurrency, prefetch, Completable.timer(1, SECONDS).toFlowable(), Flowable.interval(10, MILLISECONDS)/*.onBackpressureBuffer(capacity)*/);
you can use the commented code to control the buffering, if you have a single, that looks that it is actually a completable as you are ignoring its unique element, you can call
.ignoreElement() and the again