Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Repo info
Activity
    James Moore
    @banshee
    Got it - sounds like there's nothing builtin to do this that I'm not seeing
    Dorus
    @Dorus
    Not that i know of no.
    nicu marasoiu
    @nmarasoiu
    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
    @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
    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
    @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.
    nicu marasoiu
    @nmarasoiu
    @Dorus Thanks! We solved the issue, it was in the test apparently..
    nicu marasoiu
    @nmarasoiu
    Hi, is it possible, when merging Observables, to delay some types of errors, but do not delay other types of errors?
    Tushar Mathur
    @tusharmath
    Use filter
    and then merge
    Dorus
    @Dorus
    I think he wants to delay onError
    nicu marasoiu
    @nmarasoiu
    probably a healthy solution is to incorporate the non-fatal "errors" as part of the value
    as value types, not as error types
    and remain with mergeDelayError
    Dorus
    @Dorus
    True, especially in RxJava where errors tend to 'skip ahead' and kill any value in front of them.
    nicu marasoiu
    @nmarasoiu
    Thanks
    Dmitriy Zaitsev
    @DmitriyZaitsev

    Hey guys! your advice is needed.

    I’ve got a splash screen that should check if user authenticated and then open another screen.
    Min splash duration must be 3 sec.
    How can I sync my authObservable with timer without boolean flags?
    If I get response quickly, I'll wait. If I get response late, I’ll open a screen immediately.

    Dorus
    @Dorus
    auth.zip(Observable.timer(3000))
    That will yield 1 item from auth after min 3 seconds
    @DmitriyZaitsev
    Dmitriy Zaitsev
    @DmitriyZaitsev
    @Dorus that’s it. thanks!
    Alessandro Vermeulen
    @spockz
    Does anyone know of an implementation akin to https://github.com/ReactiveX/RxJavaReactiveStreams for RxScala?
    Srepfler Srdan
    @schrepfler
    I think there are two
    ah
    I misunderstood you
    I don’t know of such a bridge
    Pieter Vos
    @Kentaree
    Hi guys
    I'm trying to figure out the best way of combining 2 observables in sequence
    I have an existing observable, and I want to essentially return its values after another piece of code has been successfully executed
    but I'm drawing a blank
    Nam Nguyen Hoai
    @eneim

    Pardon me if posting this is not allowed here: https://github.com/google/agera

    But google seems to have some individual implementation for Android. Any ideas?

    Dorus
    @Dorus
    @Kentaree Please clarify. You want to run 2 observable simultaneous (merge), run one after the other (concat), run new observables concurrent based on the values of another one (flatMap) or run new observables serial based on the values of another one (concatMap)
    Actually flatMap = mergeMap, this even used to be an alias but i think now there's only flatMap .
    Pieter Vos
    @Kentaree
    @Dorus one after the other, I've just implemented it using concat which seems to be the most suitable one, thanks :)
    Dorus
    @Dorus
    Sounds perfect
    This message was deleted
    Alexander Dorfman
    @alexander-dorfman
    Hi !
    I am absolutely new to RxJava and have a small problem that I can't resolve.
    Dorus
    @Dorus
    @newprint We've been working with Rx for some time and know a bit more about it. However i'm afraid you did not tell us enough about the problem to give you any hints :)
    Alexander Dorfman
    @alexander-dorfman
    give me a sec, I will describe a problem
    Lalit Maganti
    @tilal6991
    @eneim if you look at the issues you'll see one of the main devs posted a difference between it and rxjava
    Alexander Dorfman
    @alexander-dorfman

    Here is my problem
    I have two classes, RAnalyticsEngine - http://pastebin.com/iZFC4DHv
    and second class RAnalyticsServiceImp - http://pastebin.com/9ZtDLb7Q

    Notice that RAnalyticsServiceImp creates Observable<RAnalyticsEngine > in line 60

    I suspect, that I don't create Observable<RAnalyticsEngine > correctly, since .create() method is never being called.
    .create method initializes some of the parts of RAnalyticsEngine.