Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Repo info
Activity
    Ben Christensen
    @benjchristensen
    Will this work for discussions?
    Shixiong Zhu
    @zsxwing
    Test #1000 foo.bar()
    val x = y + 1
    val s = x.toString
    Awesome. Markdown still works.
    Michael Nitschinger
    @daschl
    Hello everyone
    Michael Nitschinger
    @daschl
    @benjchristensen hi!
    Shixiong Zhu
    @zsxwing
    @benjchristensen will all rx projects switch to Travis?
    Horácio Filho (Fofofly)
    @horaciojcfilho
    Where did you study about Rx?
    I'm very interested in Rx but I do not know where to start :'(
    André Staltz
    @staltz
    Check out this list: http://reactivex.io/tutorials.html
    Horácio Filho (Fofofly)
    @horaciojcfilho
    Thanks a lot :D Great links :D
    Łukasz Dywicki
    @splatch
    good morning/afternoon/evening
    Horácio Filho (Fofofly)
    @horaciojcfilho
    Good all :D
    Simon Baslé
    @simonbasle
    Hi! has anyone here experience on running RxJava in a web container (JBoss, Tomcat)? it looks like Rx threads are not killed and retain a path to the ClassLoader, preventing the webapp to be GC'ed during redeployments...
    Dave Moten
    @davidmoten
    Hi Simon, I'm running RxJava in tomcat and would like the issue addressed also. The desire for a Schedulers.reset/shutdown has come up before but not in the container context and I think we should revive it. Can you raise this as an issue on RxJava github?
    Simon Baslé
    @simonbasle
    @davidmoten do you remember if there was an issue hosting the discussion about Schedulers.shutdown?
    Simon Baslé
    @simonbasle
    ah found it, reviving ReactiveX/RxJava#1730
    Rai Butera
    @Raigasm
    hey guys I’ve got a nooby Rx/bacon question: is it OK to design an observable (subject) so that it is never ‘completed’?
    Basically I want to create an observable (subject) that is populated by an async call, and that data to perpetually be updated when it is changes, for the lifetime of the application. Am I right in thinking “completed” would ‘close’ all subscriptions to the subject?
    Simon Baslé
    @simonbasle
    @raibutera that's a perfectly valid use case, an infinite stream of emissions
    Rai Butera
    @Raigasm
    anyone here confident with the RxJS style of observables/streams? I’m running into some trouble
    Aaron Tull
    @stealthcode
    @raibutera if you have specific questions about the semantics we might be able to help you or you could try talking to mattpodwysocki https://github.com/mattpodwysocki
    Rai Butera
    @Raigasm

    I don’t understand how to use RxJS Schedulers, specifically an RxJS test scheduler. I want to test a BehaviorSubject (“Output") which takes inputs from an Observable (“Source”) and another BehaviourSubject (“Updates”).

    what I want to do:

    1. subscribe to the output, assert that it starts off empty
    2. check the state of the output after the source is retrieved
    3. trigger some updates on the update
    4. check the that output BehaviourSubject after updates contains both the source and updates

    if anyone can help I’m happy to pay via paypal or something

    Ben Christensen
    @benjchristensen
    @raibutera I'm not much help for RxJS, but for RxJava can easily point to examples using a TestScheduler.
    Matt Langston
    @mattblang
    I am running two async operations with a FlatMap. I am handling the Throwable if something happens with the HTTP request, but we have also created a system on the server side that will return back a successful response with an error code for the client to handle. I'm trying to figure out what to do in the first call of the FlatMap chain if this server error is returned.
    Robert Winkler
    @RobWin
    Does it throw a runtimeException? Or do you have to parse the response and check the content?
    Matt Langston
    @mattblang
    @RobWin Parse the response and check the content. Yeah, the Throwable part I have handled np with an Action0<Throwable>.
    @RobWin Just not sure the kosher way to handle the non-throwable error (that I see when content is checked).
    Robert Winkler
    @RobWin
    Could you decorate the other API and throw an exception if the content has an error code?
    To handle all APIs the same?
    Matt Langston
    @mattblang
    @RobWin That is a really good idea man! I’m using Retrofit, which is a Java library for doing HTTP response / parsing. I could write an interceptor that checks for the error. Heck yes! Thank you. Just for my own knowledge, what would happen if I return null from the first flatMap observable?
    @RobWin (I meant HTTP request / response parsing)
    @RobWin (Err, that is still ambigious. It does the HTTP call and parses the response, lol)
    Robert Winkler
    @RobWin
    Yes I know Retrofit :)
    Not sure about the null response. You must check JavaDoc.
    Do you use Java8?
    If yes, have a look at the Try (Error-Handling) Monad of http://javaslang.com
    If you need a circuit breaker look at https://github.com/RobWin/circuitbreaker-java8
    Its new and not released yet, but I soon release the first Version.
    Robert Winkler
    @RobWin
    Maybe we move it into javaslang as a new module.
    You can decorate any function (supplier or Runnable) with a circuit breaker
    Brings some scala flavour to java8
    Matt Langston
    @mattblang
    I’ve got an interesting situation I haven’t come across yet. I do several REST calls to register a user, log them in automatically, grab their profile, etc. I’m flat mapping all of these REST calls together. In my subscriber I handle a Throwable. The tricky part is, I need to be able to do something different depending on if they error during registration or after, because if the registration is successful but the auto login / profile fetch is not I don’t want them to try to log in again. Any hints?
    Andrew Reitz
    @pieces029
    @mattblang can you use doOnError after the call you want to specifically handle? Otherwise instance of in the onError, but that sounds gross.
    Matt Langston
    @mattblang
    @pieces029 I can doOnError from the first flatMap, sure, but will that stop the chain of flatMaps?
    Matt Langston
    @mattblang
    @pieces029 Yeah, so the doOnError hits but the onError in my subscriber still picks up the error as well. If I could somehow intercept the throwable and rethrow my own custom one maybe...