These are chat archives for ReactiveX/RxJava

3rd
Oct 2016
Antonín Brettšnajdr
@LittleLightCz
Oct 03 2016 16:12
Hello there, I was wondering, is there any good way how to create a configurable Observable? E.g. I would like to write code like this: sourceDb.getObservable(Bean.class).sql("....").params(.....).subscribe(targetDb.getSubscriber())
Yannick Lecaillez
@ylecaillez
Oct 03 2016 16:56
Hi all. I'm experiencing an issue with flatMap() (basically, receiving only the 128 first items) which might come from RxJava: https://github.com/ReactiveX/RxJava/blob/2.x/src/main/java/io/reactivex/internal/operators/flowable/FlowableFlatMap.java#L122 I can't see where/when MergeSubscriber is requesting more data (s.request()) when t isn't a Callable.
Yannick Lecaillez
@ylecaillez
Oct 03 2016 17:04
done in parent.drain() sorry for the noise.