These are chat archives for ReactiveX/RxJava

21st
Nov 2016
Eido95
@Eido95
Nov 21 2016 08:48
Thank you for your link @akarnokd, I'll inspect it.
Yannick Lecaillez
@ylecaillez
Nov 21 2016 15:53
Hi guys. I had a look at the code available at https://github.com/ReactiveX/RxJava/wiki/Writing-operators-for-2.0#backpressure-and-cancellation If think there is a bug for empty stream (onComplete() called without onNext()) if subscriber does not request() items. Shouldn't be the statement if (e != r) { ... } could actually be if (e == r) { ... } ?