These are chat archives for ReactiveX/RxJava

7th
Apr 2016
nicu marasoiu
@nmarasoiu
Apr 07 2016 15:20
Hi, I used both delaySubscription with and without another Scheduler. Both do not actually induce any delay on the subscribers: for instance starting 30 observables with delays up to many seconds, merging them in a new one, and subscribing on the merged one, and they all start in 22 ms
Dorus
@Dorus
Apr 07 2016 15:25
@nmarasoiu Are you sure you are measuring the startup time, and not the execution time of subscribe? Because it should subscribe almost instantly (async code), but only does the actual work after the said delay.
I'm clueless otherwise. Perhaps share some code?
nicu marasoiu
@nmarasoiu
Apr 07 2016 15:30
we have a method m1 returning an observable in which' lambda it makes a request to ignite grid (a remoting call); we want to make a retry scheme in which we create 3 such observables with.delaySubscription of exponentially larger wait times, and we merge those in a single error delaying observble to consume from ignite, original calls or retries, as needed
but the first observables are being consumed in the same time, and only other observables truly delay subscribers but very few ms compared to hundreds of ms specified
Dorus
@Dorus
Apr 07 2016 23:26
@nmarasoiu I tried to set up what you describe, and it seems to work more or less.
Really bad code, but i wacked it down very quickly.