David Karnok

3.x: Add onDropped callbacks to operators

2

Add `onDropped` callback overloads to most operators that drop items that can't be recovered by other means. - [x] `throttleLatest` [PR #7457](https://github.com/ReactiveX/RxJava/issues/7457) - [ ] `throttleFirst` (PR TBD) - [...

3.x: Flowable missing or incorrect marbles (tracking issue)

5

- [x] `amb`: indicate cancellation and request propagation - [x] `ambArray`: indicate cancellation and request propagation - [ ] `combineLatest` + 4: missing diagram - [ ] `combineLatestDelayError` + 5:...

Update wiki to reflect 3.x (tracking issue)

22

This is the overview of the suggested/planned changes to the Wiki. *Text in bold are for extra considerations/options*. - [ ] [`Additional-Reading.md`](https://github.com/ReactiveX/RxJava/blob/3.x/docs/Additional-Reading.md): review links, add newer links to blogs and...

Javadoc mistakes to look for

4

From [this comment](https://github.com/ReactiveX/RxJava/pull/4530#issuecomment-246390124): - parameter names change in the code but the javadocs still refer to the old names - potential exceptions change in the code and the javadocs aren't...

3.x: parallel performs poorly with 10+ parallelism

3

For some reason, the parallel Scrabble benchmark performs poorly when the parallelism level is 10+, for example, on my i7 8700 CPU (6 cores/12 threads):  However, my older i7...

``` io.reactivex.rxjava3.internal.operators.flowable.FlowableConcatMapSchedulerTest > mapperDelayError2ScheduledLong FAILED java.lang.AssertionError: Not completed (latch = 1, values = 1, errors = 0, completions = 0, timeout!, disposed!) at io.reactivex.rxjava3.observers.BaseTestConsumer.fail(BaseTestConsumer.java:125) at io.reactivex.rxjava3.observers.BaseTestConsumer.assertComplete(BaseTestConsumer.java:178) at io.reactivex.rxjava3.internal.operators.flowable.FlowableConcatMapSchedulerTest.mapperDelayError2ScheduledLong(FlowableConcatMapSchedulerTest.java:1093) ```

``` io.reactivex.rxjava3.subjects.UnicastSubjectTest > fusedNoConcurrentCleanDueToCancel FAILED org.junit.runners.model.TestTimedOutException: test timed out after 5 minutes at io.reactivex.rxjava3.subjects.UnicastSubject.drainFused(UnicastSubject.java:416) at io.reactivex.rxjava3.subjects.UnicastSubject.drain(UnicastSubject.java:464) at io.reactivex.rxjava3.subjects.UnicastSubject.onNext(UnicastSubject.java:319) at io.reactivex.rxjava3.subjects.UnicastSubjectTest.fusedNoConcurrentCleanDueToCancel(UnicastSubjectTest.java:481) ```

3.x: recursive concat causes StackOverflowError

5

Originally posted on [StackOverflow](https://stackoverflow.com/questions/61160362/how-to-recursively-generate-an-rxjava-flowable-using-operators-vended-in-the-cor). The following code crashes with `StackOverflowError` and the stacktrace shows a long chain of `request` calls. ```kotlin import io.reactivex.rxjava3.core.Flowable import io.reactivex.rxjava3.core.Single import io.reactivex.rxjava3.schedulers.Schedulers import java.util.concurrent.TimeUnit.SECONDS fun...

101 Reactive Gems (working title)

22

In this issue, we should collect tips and tricks with reactive systems and dataflows. These are not particularly advanced topics but the markdown support on GitHub makes it easier to...

Gem 22) discussion

5

From @dsyer > Interesting. Do you mean Mono.fromCallable() (because when I looked at the source code it seemed to me that the Callable.call() only happens when there is a subscribe())?...